diff --git a/mqtt-zoo/mqtt-test-kafka/pom.xml b/mqtt-zoo/mqtt-test-kafka/pom.xml
index 2919f0c..2b4a1fb 100644
--- a/mqtt-zoo/mqtt-test-kafka/pom.xml
+++ b/mqtt-zoo/mqtt-test-kafka/pom.xml
@@ -10,11 +10,12 @@
1.3.0-netty
2.4.1.v20201014
- 4.1.28.Final
- 1.2.55
- 4.1.2
+ 4.1.77.Final
+ 2.0.4
+ 5.8.1
2.0.0
- 1.7.25
+ 1.7.25
+ 1.2.9
UTF-8
UTF-8
@@ -56,10 +57,21 @@
kafka_2.12
${kafka_2.12.version}
+
org.slf4j
- slf4j-log4j12
- ${slf4j-log4j12.version}
+ slf4j-api
+ ${slf4j.version}
+
+
+ ch.qos.logback
+ logback-core
+ ${logback.version}
+
+
+ ch.qos.logback
+ logback-classic
+ ${logback.version}
diff --git a/mqtt-zoo/mqtt-test-kafka/src/main/resources/META-INF/nutz/org.nutz.boot.config.ConfigureLoader b/mqtt-zoo/mqtt-test-kafka/src/main/resources/META-INF/nutz/org.nutz.boot.config.ConfigureLoader
new file mode 100644
index 0000000..fc063e2
--- /dev/null
+++ b/mqtt-zoo/mqtt-test-kafka/src/main/resources/META-INF/nutz/org.nutz.boot.config.ConfigureLoader
@@ -0,0 +1 @@
+org.nutz.boot.config.impl.YamlConfigureLoader
\ No newline at end of file
diff --git a/mqtt-zoo/mqtt-test-kafka/src/main/resources/application.properties b/mqtt-zoo/mqtt-test-kafka/src/main/resources/application.properties
deleted file mode 100644
index cad2cbd..0000000
--- a/mqtt-zoo/mqtt-test-kafka/src/main/resources/application.properties
+++ /dev/null
@@ -1,29 +0,0 @@
-# 开发环境配置
-nutz.application.name=test
-
-#kafka地址 127.0.0.1:9092,127.0.0.1:9093
-mqttwk.broker.kafka.bootstrap.servers=127.0.0.1:9092
-#acks回令 如果必须等待回令,那么设置acks为all,否则，设置为-1,等待回令会有性能损耗
-mqttwk.broker.kafka.acks=-1
-#重试次数
-mqttwk.broker.kafka.retries=0
-#批量提交大小
-mqttwk.broker.kafka.batch.size=16384
-#提交延迟等待时间（等待时间内可以追加提交）
-mqttwk.broker.kafka.linger.ms=1
-#缓存大小
-mqttwk.broker.kafka.buffer.memory=33554432
-#序列化方法
-mqttwk.broker.kafka.key.serializer=org.apache.kafka.common.serialization.StringSerializer
-mqttwk.broker.kafka.value.serializer=org.apache.kafka.common.serialization.StringSerializer
-#选择策略，可选配置
-mqttwk.broker.kafka.partitioner.class=cn.wizzer.iot.mqtt.server.store.kafka.SimplePartitioner
-
-#消费者配置项
-mqttwk.broker.kafka.key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
-mqttwk.broker.kafka.value.deserializer=org.apache.kafka.common.serialization.StringDeserializer
-
-#主题配置
-mqttwk.broker.kafka.producer.topic=mqtt_publish
-mqttwk.broker.kafka.consumer.topic=mqtt_subscribe
-mqttwk.broker.kafka.group.id=mqttwk
diff --git a/mqtt-zoo/mqtt-test-kafka/src/main/resources/application.yaml b/mqtt-zoo/mqtt-test-kafka/src/main/resources/application.yaml
new file mode 100644
index 0000000..c6080e5
--- /dev/null
+++ b/mqtt-zoo/mqtt-test-kafka/src/main/resources/application.yaml
@@ -0,0 +1,40 @@
+nutz:
+ application:
+ name: test
+
+mqttwk:
+ broker:
+ kafka:
+ # 鏄惁鍚敤kafka娑堟伅杞彂
+ broker-enabled: false
+ bootstrap:
+ # kafka鍦板潃 127.0.0.1:9092,127.0.0.1:9093
+ servers: 127.0.0.1:9092
+ # acks鍥炰护 濡傛灉蹇呴』绛夊緟鍥炰护,閭ｄ箞璁剧疆acks涓篴ll,鍚﹀垯锛岃缃负-1,绛夊緟鍥炰护浼氭湁鎬ц兘鎹熻
+ acks: -1
+ # 閲嶈瘯娆℃暟
+ retries: 3
+ batch:
+ # 鎵归噺鎻愪氦澶у皬
+ size: 16384
+ linger:
+ # 鎻愪氦寤惰繜绛夊緟鏃堕棿锛堢瓑寰呮椂闂村唴鍙互杩藉姞鎻愪氦锛
+ ms: 1
+ buffer:
+ # 缂撳瓨澶у皬
+ memory: 33554432
+ key:
+ # 搴忓垪鍖栨柟寮
+ serializer: org.apache.kafka.common.serialization.StringSerializer
+ value:
+ # 搴忓垪鍖栨柟寮
+ serializer: org.apache.kafka.common.serialization.StringSerializer
+ partitioner:
+ class: cn.wizzer.iot.mqtt.server.store.kafka.SimplePartitioner
+ producer:
+ # kafka杞彂鐨勪富棰
+ topic: mqtt_publish
+ consumer:
+ topic: mqtt_subscribe
+ group:
+ id: mqttwk
diff --git a/mqtt-zoo/mqtt-test-kafka/src/main/resources/log4j.properties b/mqtt-zoo/mqtt-test-kafka/src/main/resources/log4j.properties
deleted file mode 100644
index d8a9e24..0000000
--- a/mqtt-zoo/mqtt-test-kafka/src/main/resources/log4j.properties
+++ /dev/null
@@ -1,7 +0,0 @@
-log4j.rootLogger=debug,Console
-
-log4j.logger.org.apache.kafka=info
-
-log4j.appender.Console=org.apache.log4j.ConsoleAppender
-log4j.appender.Console.layout=org.apache.log4j.PatternLayout
-log4j.appender.Console.layout.ConversionPattern=[%-5p] %d{HH:mm:ss.SSS} %l - %m%n
\ No newline at end of file
diff --git a/mqtt-zoo/mqtt-test-kafka/src/main/resources/logback.xml b/mqtt-zoo/mqtt-test-kafka/src/main/resources/logback.xml
new file mode 100644
index 0000000..855b5e7
--- /dev/null
+++ b/mqtt-zoo/mqtt-test-kafka/src/main/resources/logback.xml
@@ -0,0 +1,44 @@
+
+
+
+
+
+ %highlight(%date{yyyy-MM-dd HH:mm:ss.SSS}) %cyan([%thread]) %yellow(%-5level) %green(%logger{36}).%gray(%M)-%boldMagenta(%line) - %blue(%msg%n)
+
+
+
+
+
+
+ logs/test-%d{yyyy-MM-dd}.%i.txt
+
+ 50MB
+ 30
+ 1GB
+
+
+ [%-5level] %d{HH:mm:ss.SSS} %logger - %msg%n
+
+
+
+
+
+
+
+ 0
+
+ 256
+
+
+
+
+
+
+
+
+
+
+
+
+
+