如题,nginx负载两个tomcat集群,当消费kafka的时候出现了同个消息被消费了两次,请问是为什么。
消费者组名要相同。
组名相同
如果组名相同,也重复,则要看你是的提交offset逻辑了,是手动还是自动。
使用的是spring的@KafkaListener,
不适用tomcat集群 单个使用的时候是没有问题的。
这跟tomcat没关系吧,是手动提交还是自动提交?
取消了kafka的自动,使用的@KafkaListener,他会帮你提交的
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list看看你的消费者列表,有没有多的,不同的。
恩
找不到想要的答案?提一个您自己的问题。
0 声望
这家伙太懒,什么都没留下
消费者组名要相同。
组名相同
如果组名相同,也重复,则要看你是的提交offset逻辑了,是手动还是自动。
使用的是spring的@KafkaListener,
不适用tomcat集群 单个使用的时候是没有问题的。
这跟tomcat没关系吧,是手动提交还是自动提交?
取消了kafka的自动,使用的@KafkaListener,他会帮你提交的
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list
看看你的消费者列表,有没有多的,不同的。
恩
你的答案