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

请参阅此答案：/sf/answers/3566839041/ 和/sf/answers/3541683281/

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