We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 43c1a76 commit 41b8ad0Copy full SHA for 41b8ad0
spring-kafka/src/main/java/com/baeldung/kafka/embedded/KafkaConsumer.java
@@ -18,7 +18,7 @@ public class KafkaConsumer {
18
19
private String payload;
20
21
- @KafkaListener(topics = "${test.topic}")
+ @KafkaListener(topics = "${test.topic}", groupId = "${test.groupid}")
22
public void receive(ConsumerRecord<?, ?> consumerRecord) {
23
LOGGER.info("received payload='{}'", consumerRecord.toString());
24
spring-kafka/src/main/resources/application.properties
@@ -14,6 +14,7 @@ monitor.producer.simulate=true
14
monitor.consumer.simulate=true
15
monitor.kafka.consumer.groupid.simulate=baeldungGrpSimulate
16
test.topic=testtopic1
17
+test.groupid=baeldung
0 commit comments