From eb6234d2f2f6deceb46e94d5d019749879516aeb Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 13 Nov 2022 14:29:09 +0100 Subject: [PATCH] Konfiguration in @KafkaListener vereinfacht --- src/main/java/de/juplo/kafka/SimpleConsumer.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/src/main/java/de/juplo/kafka/SimpleConsumer.java b/src/main/java/de/juplo/kafka/SimpleConsumer.java index 31c7e6b..fe0479f 100644 --- a/src/main/java/de/juplo/kafka/SimpleConsumer.java +++ b/src/main/java/de/juplo/kafka/SimpleConsumer.java @@ -17,10 +17,7 @@ public class SimpleConsumer private String id; private long consumed = 0; - @KafkaListener( - id = "${spring.kafka.client-id}", - groupId = "${spring.kafka.consumer.group-id}", - topics = "${simple.consumer.topic}") + @KafkaListener(topics = "${simple.consumer.topic}") private void handleRecord( @Header(KafkaHeaders.RECEIVED_TOPIC) String topic, -- 2.20.1