消息被消费两次

Question

Kafka 集群中有一个 8 个分区的主题。 我实现了使用 KafkaMessageDrivenChannelAdapter 来消费主题的应用程序，并发数为 8，offsetManager 是 KafkaTopicOffsetManager。 当我启动一个应用程序实例时，一切都是正确的。但是当我启动两个应用程序实例时，我发现 meesge 被消耗了两次。你知道为什么以及如何解决它吗？我需要更改为 highLevelConsumer？

Answer 1

您必须使用该适配器跨实例分配分区。

我们正在努力升级到支持消费者组的 kafka 0.9 java 客户端。

The first milestone for the core project is available.

我们需要努力发布使用这个新客户端的 spring-integration-kafka 2.0 里程碑。