kafka consumer AbstractCoordinator：发现了协调器Java客户端

Question

我有3个代理运行代理ID为0 1和2的代理.Consumer（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

Answer 1

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

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