OrcHome OrcHome
OrcHome个人中心.

余生。

已关注 关注

关注

暂无关注.....

粉丝

暂无粉丝.....


余生。 回复 半兽人 在 nginx负载两个tomcat集群，当消费kafka的时候出现了同个消息被消费了两次，请问是为什么。 中:
恩       
3月前
半兽人 回复 余生。 在 nginx负载两个tomcat集群，当消费kafka的时候出现了同个消息被消费了两次，请问是为什么。 中:
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list
看看你的消费者列表，有没有多的，不同的。
3月前
余生。 回复 半兽人 在 nginx负载两个tomcat集群，当消费kafka的时候出现了同个消息被消费了两次，请问是为什么。 中:
取消了kafka的自动，使用的@KafkaListener，他会帮你提交的
3月前
半兽人 回复 余生。 在 nginx负载两个tomcat集群，当消费kafka的时候出现了同个消息被消费了两次，请问是为什么。 中:
这跟tomcat没关系吧，是手动提交还是自动提交？
3月前
余生。 回复 半兽人 在 nginx负载两个tomcat集群，当消费kafka的时候出现了同个消息被消费了两次，请问是为什么。 中:
不适用tomcat集群 单个使用的时候是没有问题的。
3月前
余生。 回复 半兽人 在 nginx负载两个tomcat集群，当消费kafka的时候出现了同个消息被消费了两次，请问是为什么。 中:
使用的是spring的@KafkaListener，
3月前
余生。 回复 半兽人 在 nginx负载两个tomcat集群，当消费kafka的时候出现了同个消息被消费了两次，请问是为什么。 中:
组名相同
3月前
半兽人 回复 余生。 在 kafka中文教程 中:
http://orchome.com/1000
3月前
余生。 在 kafka中文教程 发表评论:
nginx负载两个tomcat集群，当消费kafka的时候出现了同个消息被消费了两次，请问是为什么。
3月前
发表了 nginx负载两个tomcat集群，当消费kafka的时候出现了同个消息被消费了两次，请问是为什么。
3月前
半兽人 回复 余生。 在 kafka入门介绍 中:
没 要自己实现。
3月前
余生。 回复 半兽人 在 kafka入门介绍 中:
我说的就是这样的消息要放到多个分区不能指定在一个特定的分区里。  我想问的就是在一个分区有没有实现多线程的例子
3月前
半兽人 回复 余生。 在 kafka入门介绍 中:
没懂，假设一个场景。
假设一个topic有3个分区，假设你有一个应用，要部署3台，这样的话每一台都会分到1个分区。
如果在这个基础上实现多线程，就是我上面说的，每台服务器在拉取到消息之后，进行多线程处理。

3月前
余生。 回复 半兽人 在 kafka入门介绍 中:
是不是这样生产者就不能使用一个分区去发送消息了，我看网上说的是使用多个分区，然后消费者遍历，消费。
3月前
半兽人 回复 余生。 在 kafka入门介绍 中:
多线程要在 poll()之后实现。
3月前
半兽人 回复 余生。 在 kafka入门介绍 中:
读取消息，然后多线程。
3月前
余生。 在 kafka入门介绍 发表评论:
kafka如何配置多线程消费
3月前

余生。 回复 半兽人 在 nginx负载两个tomcat集群，当消费kafka的时候出现了同个消息被消费了两次，请问是为什么。 评论:
恩       
3月前
半兽人 回复 余生。 在 nginx负载两个tomcat集群，当消费kafka的时候出现了同个消息被消费了两次，请问是为什么。 评论:
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list
看看你的消费者列表，有没有多的，不同的。
3月前
余生。 回复 半兽人 在 nginx负载两个tomcat集群，当消费kafka的时候出现了同个消息被消费了两次，请问是为什么。 评论:
取消了kafka的自动，使用的@KafkaListener，他会帮你提交的
3月前
半兽人 回复 余生。 在 nginx负载两个tomcat集群，当消费kafka的时候出现了同个消息被消费了两次，请问是为什么。 评论:
这跟tomcat没关系吧，是手动提交还是自动提交？
3月前
余生。 回复 半兽人 在 nginx负载两个tomcat集群，当消费kafka的时候出现了同个消息被消费了两次，请问是为什么。 评论:
不适用tomcat集群 单个使用的时候是没有问题的。
3月前
余生。 回复 半兽人 在 nginx负载两个tomcat集群，当消费kafka的时候出现了同个消息被消费了两次，请问是为什么。 评论:
使用的是spring的@KafkaListener，
3月前
余生。 回复 半兽人 在 nginx负载两个tomcat集群，当消费kafka的时候出现了同个消息被消费了两次，请问是为什么。 评论:
组名相同
3月前
半兽人 回复 余生。 在 kafka中文教程 评论:
http://orchome.com/1000
3月前
余生。 在 kafka中文教程 发表评论:
nginx负载两个tomcat集群，当消费kafka的时候出现了同个消息被消费了两次，请问是为什么。
3月前
半兽人 回复 余生。 在 kafka入门介绍 评论:
没 要自己实现。
3月前
余生。 回复 半兽人 在 kafka入门介绍 评论:
我说的就是这样的消息要放到多个分区不能指定在一个特定的分区里。  我想问的就是在一个分区有没有实现多线程的例子
3月前
半兽人 回复 余生。 在 kafka入门介绍 评论:
没懂，假设一个场景。
假设一个topic有3个分区，假设你有一个应用，要部署3台，这样的话每一台都会分到1个分区。
如果在这个基础上实现多线程，就是我上面说的，每台服务器在拉取到消息之后，进行多线程处理。

3月前
余生。 回复 半兽人 在 kafka入门介绍 评论:
是不是这样生产者就不能使用一个分区去发送消息了，我看网上说的是使用多个分区，然后消费者遍历，消费。
3月前
半兽人 回复 余生。 在 kafka入门介绍 评论:
多线程要在 poll()之后实现。
3月前
半兽人 回复 余生。 在 kafka入门介绍 评论:
读取消息，然后多线程。
3月前
余生。 在 kafka入门介绍 发表评论:
kafka如何配置多线程消费
3月前