如何在多個消費者閱讀相同的kafka消息

Question

我對Kakfa Spring集成非常陌生。我已經實現了Kafka消息發送和One Listener，它對我來說工作得很好。但我想在兩個地方聽同樣的信息。誰能幫我。以下是我的代碼。

spring.kafka.bootstrap-servers=localhost:9092 
spring.kafka.consumer.auto-commit-interval=100 
spring.kafka.consumer.bootstrap-servers=localhost:9092 
spring.kafka.consumer.enable-auto-commit=true 
spring.kafka.consumer.group-id=sample-group 


spring.kafka.producer.batch-size= 16384 
spring.kafka.producer.bootstrap-servers=localhost:9092 
spring.kafka.producer.retries= 0 
spring.kafka.producer.buffer-memory=33554432 

spring.kafka.template.default-topic=spring-topic 

發件人代碼：

public void testSimple() { 
     System.out.println("Sending Topic Here"); 
     template.send("spring-topic", 0, "foo"); 
     template.flush(); 
    } 

接收機：

@KafkaListener(id = "foo", topics = "spring-topic") 
    public void listen1(String foo) { 
     System.out.println("Got Notification Here"); 
     this.latch1.countDown(); 
    } 

任何能幫助我如何在不同的地方讀取相同的消息。

Answer 1

如果你改變了消費羣體在這條線：

spring.kafka.consumer.group-id=sample-group 

到別的第二消費將得到所有信息，以及東西。

This article解釋了一些有關消費者羣體，值得一讀。