我正在使用spring-cloud-stream-kafka . 我正在使用相同的组名称 testGroup 开始消费者应用程序的2个实例消耗来自Kafka主题 testTopic 的单个分区的消息，我希望其中一个消费者实例使用来自Kafka主题的消息而另一个实例不消耗任何东西，因为他们共享相同的组名 . 我正在使用0.8.xx版本的Kafka客户端 . 这是我的 property
spring.cloud.stream.bindings.input.destination=testTopic
spring.cloud.stream.bindings.input.group=testGroup
知道会发生什么吗？
2 回答
是的，这是我们使用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 .
您使用的是哪个版本的Spring Cloud Stream？我认为您正在使用支持Kafka
0.8.xx版本的Spring Cloud Stream的1.0.3版本 . 无论如何，这看起来像一个bug .此外，在使用Kafka 0.9或0.10与Spring Cloud Stream 1.1.x时，我没有看到此问题 .