From 747054a10ecfc540a39507e9db69834d820a4903 Mon Sep 17 00:00:00 2001
From: huangqizhen <huangqizhen@legu168.com>
Date: Fri, 20 Dec 2024 16:39:09 +0800
Subject: [PATCH] =?UTF-8?q?=E5=90=8E=E7=AB=AF=E6=95=B4=E5=90=88=E6=A8=A1?=
 =?UTF-8?q?=E5=9D=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 pom.xml                            |  5 ++---
 src/main/resources/application.yml | 16 ++++++++++++++--
 2 files changed, 16 insertions(+), 5 deletions(-)

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/
-