前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家。点击跳转到网站。
一、场景
1.1、场景应用环境
- 卡夫卡:2.11-1.0.1。
- 主题:并发度为 5 且分区为 5 。
1.2、 问题重现
-
当应用程序重新启动并且在分区分配之前在主题上发布消息时,主题的 5 个消费者找到组协调器并向组协调器发送加入组请求。预计会得到团体协调员的答复,但没有收到任何答复,并且在Kafka服务器日志中找不到DEBUG 日志级别的相关日志。文章来源:https://www.toymoban.com/news/detail-676185.html
-
运行描述消费者组命令时,出现以下结果:
a. 消费群体正在重新平衡。
b. 老消费者,有一定滞后性。
c. 具有一些随机名称的新消费者。随着时间的推移,新的消费者数量不断增加。
d.新消息发布在主题上,但消费者没有收到。<文章来源地址https://www.toymoban.com/news/detail-676185.html
到了这里,关于Kafka 消费者“group_name”组正在永远重新平衡的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!