如何在多个消费者处读取相同的 kafka 消息答案

【问题标题】：How to read same kafka message at multiple Consumer如何在多个消费者处读取相同的 kafka 消息
【发布时间】：2017-03-02 18:09:03
【问题描述】：

我对 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();
    }

任何人都可以帮助我如何在不同的地方阅读相同的消息。

【问题讨论】：

标签： apache-kafka kafka-consumer-api kafka-producer-api spring-kafka

【解决方案1】：

如果你在这一行更改了消费者组：

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

对于第二个消费者中的其他东西，它也会收到所有消息。

This article 解释了更多关于消费群体的内容，值得一读。

【讨论】：