首页 > 解决方案 > 如果头两个卡夫卡进程也停止,卡夫卡消费者工作失败

问题描述

1.环境

卡夫卡版本:0.11.0.1。

2.问题描述

不管有多少kafka节点,如果停止head 2 kafka进程,那么consumer无法从kafka获取消息(producer可以向kafka发送消息),经过检查,head 2 kafka节点是consumer group coordinators,如果有一个挂了,另一个会继续工作,如果两个都挂了,消费者不工作,报错:偏移提交失败,这不是正确的协调者。

3. 我的问题。

我的测试结果正确吗?如果测试结果正确,似乎 kafka 不支持可用的高度。

如果我的测试结果是错误的,有什么问题?

标签: apache-kafka

解决方案


之所以找到原因,是因为__consumer_offsets的replication factor配置为2(head 2 kafka节点),所以不管有多少kafka节点,如果head 2 kafka节点down了,都会报错:commit offset failed。


推荐阅读