From 5af92950ee2ff708994079e4b1d9cd68d68165da Mon Sep 17 00:00:00 2001
From: Hao Miao <47212914+PushM@users.noreply.github.com>
Date: Thu, 1 Feb 2024 16:02:24 +0800
Subject: [PATCH] =?UTF-8?q?1=E3=80=81=E4=BF=AE=E6=94=B9@KafkaListener=20id?=
 =?UTF-8?q?=20topic=E4=B8=BA=E5=9B=BA=E5=AE=9A=E5=80=BC?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../protection/configuration/kafka/KafkaTopicConfig.java        | 2 +-
 .../server/alertmessage/kafkaProducer/KafkaConsumerService.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/realtime/protection/configuration/kafka/KafkaTopicConfig.java b/src/main/java/com/realtime/protection/configuration/kafka/KafkaTopicConfig.java
index c8fddd6..d05b4d3 100644
--- a/src/main/java/com/realtime/protection/configuration/kafka/KafkaTopicConfig.java
+++ b/src/main/java/com/realtime/protection/configuration/kafka/KafkaTopicConfig.java
@@ -8,6 +8,6 @@ import org.springframework.context.annotation.Configuration;
 public class KafkaTopicConfig {
     @Bean
     public NewTopic batchTopic() {
-        return new NewTopic("testTopic", 4, (short) 1);
+        return new NewTopic("topic-alert", 4, (short) 1);
     }
 }
diff --git a/src/main/java/com/realtime/protection/server/alertmessage/kafkaProducer/KafkaConsumerService.java b/src/main/java/com/realtime/protection/server/alertmessage/kafkaProducer/KafkaConsumerService.java
index 7e13272..1d92934 100644
--- a/src/main/java/com/realtime/protection/server/alertmessage/kafkaProducer/KafkaConsumerService.java
+++ b/src/main/java/com/realtime/protection/server/alertmessage/kafkaProducer/KafkaConsumerService.java
@@ -15,7 +15,7 @@ public class KafkaConsumerService {
         this.alertMessageService = alertMessageService;
     }
 
-    @KafkaListener(id = "${spring.kafka.consumer.group-id}", topics = "${spring.kafka.consumer.topic-name}",
+    @KafkaListener(id = "AlertGroup", topics = "topic-alert",
             errorHandler = "myKafkaListenerErrorHandler",
             properties = {"spring.json.value.default.type=com.realtime.protection.configuration.entity.alert.AlertMessage"})
     public void consume(AlertMessage alert, Acknowledgment ack) {