慕容紫枫

个人觉得应该分清 commitedOffset 和 endOffset, 如果只是说 offset, 会让人同意混淆新加入的 consumer group的起始消费位置

不错不错哟

不好意思,我@KafkaListener中的内容没有贴全,修改了一下问题

如果你想 B 和 C 都消费topic的所有数据 可以这样指定不同的groupId，比如

• B：@KafkaListener(topics = "topic",groupId = "B1")
• C：@KafkaListener(topics = "topic",groupId = "C1")

你这个消费者注解里面的内容不全，建议贴全一点，如果两个消费者没设置groupId的话默认使用同一个groupId 而且订阅的topic是一个的话 topic中的每条消息只会发给B或者C中的一个，不会都发。建议你安装一下Kafka监控工具 比如kafka-manager，然后开通JMX监听，启动kafka-manager之后可以看到消费者的消费情况。