apache-kafka - 如果头两个卡夫卡进程也停止,卡夫卡消费者工作失败
问题描述
1.环境
卡夫卡版本:0.11.0.1。
2.问题描述
不管有多少kafka节点,如果停止head 2 kafka进程,那么consumer无法从kafka获取消息(producer可以向kafka发送消息),经过检查,head 2 kafka节点是consumer group coordinators,如果有一个挂了,另一个会继续工作,如果两个都挂了,消费者不工作,报错:偏移提交失败,这不是正确的协调者。
3. 我的问题。
我的测试结果正确吗?如果测试结果正确,似乎 kafka 不支持可用的高度。
如果我的测试结果是错误的,有什么问题?
解决方案
之所以找到原因,是因为__consumer_offsets的replication factor配置为2(head 2 kafka节点),所以不管有多少kafka节点,如果head 2 kafka节点down了,都会报错:commit offset failed。
推荐阅读
- android - android studio的firebase数据库中的数据未显示(未上传)
- java - 如何在不可移动的外部设备上创建公用文件夹
- php - 具有相互关联的周期性的存储服务和活动
- json - Groovy - 解析响应中仅存在某些值的 JSON
- gams-math - GAMS 中的 Floyd-Warshall 算法
- html - HTML 有序列表编号仍处于删除状态
- javascript - 如何将 Bootstrap DatePicker(年/月)实现到 Django 管理过滤器?
- html - 如何在不使用 position:absolute 的情况下在 css 中实现这种风格?
- ssl - IBM DB2 JDBC 通过 SSL 连接到编目数据库
- css - CSS flex-box:尽管 justify-content 和 align-items 设置正确,但文本并不完全居中