慕容紫枫

0 声望

这家伙太懒,什么都没留下

个人动态

你的笑靥 回复 慕容紫枫 kafka消息堆积怎么解决? 中 :
不好意思,我@KafkaListener中的内容没有贴全,修改了一下问题
1月前
慕容紫枫 kafka消息堆积怎么解决? 发表评论:
如果你想B 和 C 都消费topic的所有数据 可以这样指定不同的groupId 比如 B:@KafkaListener(topics = "topic",groupId = "B1") C:@KafkaListener(topics = "topic",groupId = "C1")
1月前
慕容紫枫 kafka消息堆积怎么解决? 发表评论:
你这个消费者注解里面的内容不全,建议贴全一点,如果两个消费者没设置groupId的话默认使用同一个groupId 而且订阅的topic是一个的话 topic中的每条消息只会发给B或者C中的一个,不会都发。建议你安装一下Kafka监控工具 比如kafka-manager,然后开通JMX监听,启动kafka-manager之后可以看到消费者的消费情况。
1月前
半兽人 如何排查kafka 消费者自动停止的问题? 发表评论:
看下os系统日志,搜下是否有OOM或者kill相关的日志。 日志目录'/var/log/messages'
1月前
关注了用户 半兽人 · 1月前

(゚∀゚ )
暂时没有任何数据