kafka消费者AbstractCoordinator：发现协调器Java客户端

Posted 2023-03-10

【中文标题】kafka消费者AbstractCoordinator：发现协调器Java客户端

【英文标题】：kafka consumer AbstractCoordinator: Discovered coordinator Java client

【发布时间】：2017-01-31 17:41:12

【问题描述】：

我有 3 个代理运行，代理 id 为 0 1 和 2。消费者（Java 客户端）选择代理 0 作为组协调器并开始正确使用消息。但是当作为组协调器的代理 0 关闭时，消费者不做任何事情并停止 poll() 方法。仅当代理 0 启动并运行时，该过程才会恢复。

如何处理 Java 客户端中组协调员更改的这种情况？

我在小组协调员去世时收到此错误：

16/09/22 17:42:45 INFO internals.AbstractCoordinator: Discovered coordinator datascience1.sv2.trulia.com:9092 (id: 2147483647 rack: null) for group group2.
16/09/22 17:42:45 INFO internals.AbstractCoordinator: (Re-)joining group group2
16/09/22 17:42:45 INFO internals.AbstractCoordinator: Marking the coordinator datascience1.sv2.trulia.com:9092 (id: 2147483647 rack: null) dead for group group2

【问题讨论】：

你得到答案了吗？

我在同样的问题上苦苦挣扎，生产者一直在发帖，但消费者却停滞不前，直到协调员回来。

你用的是什么kafka版本？是否启用了日志清理器？消费者偏移量主题是一个压缩日志，如果禁用日志清理器，这可能会导致协调器问题。

您的主题是否具有复制因子 3？是否所有副本都与领导者同步？

【参考方案1】：

看到这个答案：https://***.com/a/50954843/7321097 和https://***.com/a/50595475/7321097

问题在 offsets.topic.replication.factor & replication.factor 配置中。