nginx负载两个tomcat集群,当消费kafka的时候出现了同个消息被消费了两次,请问是为什么。

余生。 发表于: 2018-06-14   最后更新时间: 2018-06-14 11:13:21   3,119 游览

如题,
nginx负载两个tomcat集群,当消费kafka的时候出现了同个消息被消费了两次,请问是为什么。

发表于 2018-06-14
添加评论

消费者组名要相同。

余生。 -> 半兽人 6年前

组名相同

如果组名相同,也重复,则要看你是的提交offset逻辑了,是手动还是自动。

余生。 -> 半兽人 6年前

使用的是spring的@KafkaListener,

余生。 -> 半兽人 6年前

不适用tomcat集群 单个使用的时候是没有问题的。

半兽人 -> 余生。 6年前

这跟tomcat没关系吧,是手动提交还是自动提交?

余生。 -> 半兽人 6年前

取消了kafka的自动,使用的@KafkaListener,他会帮你提交的

半兽人 -> 余生。 6年前

bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list
看看你的消费者列表,有没有多的,不同的。

余生。 -> 半兽人 6年前

恩       

你的答案

查看kafka相关的其他问题或提一个您自己的问题