我在使用kafka时找到了我的问题的答案。
我正在使用kafka version 2.1.0
和kafka连接在一起。
我在用的时候,
[2019-02-24 13:23:17,056] INFO [GroupMetadataManager brokerId = 2]第12代转换为Dead的组主题名称(kafka.coordinator.group.GroupMetadataManager)
上面的错误发生在kafka代理上,之后,生产者和消费者都处于超时状态,因为经纪人不接受该请求。
它不会与kakfa-server-stop.sh
关闭。它在强制终止进程后不断重启。我认为某处存在僵局,但原因是什么?
我无法理解,因为即使kafka connect出现错误,它也不应该影响代理。
我很感激你的帮助。
最后,我找到了解决方案。我已经分析了线程转储,它类似于这个https://issues.apache.org/jira/browse/KAFKA-7697的情况
我将kafka版本从2.1.0升级到2.1.1