apache-kafka - 如何在多个消费者处读取相同的 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

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

这篇文章解释了更多关于消费群体的信息，值得一读。