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) {