diff --git a/pom.xml b/pom.xml
index f4365b3..b72f36a 100644
--- a/pom.xml
+++ b/pom.xml
@@ -27,12 +27,11 @@
 		<dependency>
 			<groupId>org.apache.kafka</groupId>
 			<artifactId>kafka-clients</artifactId>
-			<version>2.8.0</version>
+			<version>3.4.0</version>
 		</dependency>
 		<dependency>
 			<groupId>org.apache.kafka</groupId>
-			<artifactId>kafka_2.12</artifactId>
-			<version>2.8.0</version>
+			<artifactId>kafka_2.13</artifactId>
 		</dependency>
 
 		<!--		<dependency>-->
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index c93c340..7a2e971 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -16,7 +16,7 @@ spring:
       pool-name: HwgoldHikariCP # 连接池名称
     driver-class-name: com.mysql.cj.jdbc.Driver
     url: jdbc:mysql://39.101.133.168/hwgold?serverTimezone=GMT%2b8
-    username:  hwgold
+    username: hwgold
     password: 'AGX4Z3YMxiCG3GR2'
   application:
     name: demo
@@ -37,6 +37,19 @@ spring:
           max-wait: -1  # 最大阻塞等待时间（负数表示没有限制）
           max-idle: 5  # 连接池中最大空闲连接
           min-idle: 0  # 连接池中最小空闲连接
+  kafka:
+    bootstrap-servers: localhost:9092
+    producer:
+      key-serializer: org.apache.kafka.common.serialization.StringSerializer
+      value-serializer: org.apache.kafka.common.serialization.StringSerializer
+      acks: all
+      retries: 1
+    consumer:
+      group-id: my-group
+      auto-offset-reset: earliest
+      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
+      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
+
 mybatis:
   configuration:
     map-underscore-to-camel-case: true
@@ -44,4 +57,3 @@ mybatis:
 
 upload:
   path: D:/gold1/
-