【发布时间】：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？是否所有副本都与领导者同步？
标签： apache-kafka kafka-consumer-api