spring-cloud-stream-kafka不尊重单个消费者的群体

我正在使用spring-cloud-stream-kafka。我从卡夫卡话题testTopic与单个分区启动消费应用的两个实例使用相同的组名testGroup消费消息，我预计消费者一个实例为使用来自卡夫卡的话题，其他实例的消息不消费任何东西，因为他们共享相同的组名称。我正在使用0.8.xx版本的Kafka客户端。这里是我的物业spring-cloud-stream-kafka不尊重单个消费者的群体

spring.cloud.stream.bindings.input.destination=testTopic 

spring.cloud.stream.bindings.input.group=testGroup

任何想法可能发生什么？

来源

2016-11-15 Amit Bartake

您正在使用哪个版本的Spring Cloud Stream？我想你使用的是支持Kafka 0.8.xx版本的Spring Cloud Stream的1.0.3版本。无论如何，这看起来像一个错误。

另外，在Spring Cloud Stream 1.1.x中使用Kafka 0.9或0.10时，我没有看到这个问题。

来源

2016-11-15 09:38:21

我使用Brixton.SR6其中拉动弹簧云起动流卡夫卡（1.0.2.RELEASE） –

没错，那是我们使用SimpleConsumer API时1.0.3/0.8的预期行为。您无需在1.1之后执行此操作 - 详情请参阅http://docs.spring.io/spring-cloud-stream/docs/1.0.3.RELEASE/reference/htmlsingle/index.html#_instance_index_and_instance_count。

来源

2016-11-15 16:03:16

这是否意味着我不能有与单个分区一个主题并具有相同的基团指向2个消费者实例它只有一个实例正在消费消息。我需要为弹性设置多个消费者实例 –

否，这意味着您需要按照链接中的说明进行操作，并为每个正在运行的实例相应地配置实例索引和实例计数。 –

spring-cloud-stream-kafka不尊重单个消费者的群体

回答

相关问题