여러 소비자가 동일한 카프카 메시지를 읽는 방법

Question

나는 Kakfa Spring 통합에있어 매우 새로운 기술입니다. 나는 Kafka 메시지 전송과 One Listener를 구현했으며 나에게 잘 작동했다. 하지만 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(); 
    } 

어떤 방법 다른 장소에서 동일한 메시지를 읽는 나에게 도움이 될 수 있습니다.

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

그것뿐만 아니라 모든 메시지를 얻을 것이다 번째 소비자에 뭔가 다른 :이 라인에서 소비자 그룹을 변경하는 경우

Answer 1

.

This article은 소비자 그룹에 대해 더 자세히 설명하고 읽을만한 가치가 있습니다.