From a37dd6cf5655dd26f5ab5b8c7964ea4ff9f3f39b Mon Sep 17 00:00:00 2001
From: Saisai Liu <1374434128@qq.com>
Date: Mon, 10 Jun 2024 19:47:31 +0800
Subject: [PATCH] =?UTF-8?q?feat():1=E3=80=81=E5=BC=80=E5=A7=8B=E5=AD=98?=
 =?UTF-8?q?=E5=85=A5kafka--topic--=E5=88=86=E5=8C=BA=E5=AE=8C=E6=88=90?=
 =?UTF-8?q?=EF=BC=8C=E5=8F=AF=E6=8E=A8=E5=85=A5=E5=85=B6=E4=BB=96=E5=88=86?=
 =?UTF-8?q?=E5=8C=BA=202=E3=80=81=E5=AD=A6=E4=B9=A0spring=E4=B8=8B?=
 =?UTF-8?q?=E7=BA=BF=E6=89=A7=E8=A1=8C=E4=BA=8B=E4=BB=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/mobai/MqttApplicationListener.java   | 15 +++++++++++++++
 src/main/java/com/mobai/kafka/KafkaPCUtils.java   | 12 +++++++-----
 2 files changed, 22 insertions(+), 5 deletions(-)
 create mode 100644 src/main/java/com/mobai/MqttApplicationListener.java

diff --git a/src/main/java/com/mobai/MqttApplicationListener.java b/src/main/java/com/mobai/MqttApplicationListener.java
new file mode 100644
index 0000000..64cde04
--- /dev/null
+++ b/src/main/java/com/mobai/MqttApplicationListener.java
@@ -0,0 +1,15 @@
+package com.mobai;
+
+import org.springframework.context.ApplicationListener;
+import org.springframework.context.event.ContextClosedEvent;
+import org.springframework.stereotype.Component;
+
+@Component
+public class MqttApplicationListener implements ApplicationListener<ContextClosedEvent> {
+
+    @Override
+    public void onApplicationEvent(ContextClosedEvent event) {
+
+        System.out.println("下线前执行了");;
+    }
+}
diff --git a/src/main/java/com/mobai/kafka/KafkaPCUtils.java b/src/main/java/com/mobai/kafka/KafkaPCUtils.java
index fb7454c..1aeca98 100644
--- a/src/main/java/com/mobai/kafka/KafkaPCUtils.java
+++ b/src/main/java/com/mobai/kafka/KafkaPCUtils.java
@@ -20,10 +20,7 @@ import org.springframework.kafka.annotation.KafkaListener;
 import org.springframework.stereotype.Service;
 
 import java.nio.charset.StandardCharsets;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Properties;
+import java.util.*;
 
 /**
  * 生产者/消费者
@@ -71,7 +68,12 @@ public class KafkaPCUtils {
                 vin.getBytes(),
                 vehicleString,
                 vehicleString.getBytes(),
-                new Cluster("iYl5vA6ESGaoH5veXYGroQ", list, partitionInfos, null, null)
+                new Cluster(
+                        "iYl5vA6ESGaoH5veXYGroQ",
+                        list,
+                        partitionInfos,
+                        new HashSet<String>() {},
+                        new HashSet<>())
         );
         log.info("当前获取分区：[{}]",partition);
         // 创建消息  主题  key  分区  值