首页 > 解决方案 > Kafka 偏移量提交在偏移量 29 处的分区 test3-0 上失败:这不是正确的协调器

问题描述

当我测试Kafka时,发生了错误。没看懂什么意思,有三台服务器,我关闭了另外两台没有任何问题,但是当我关闭另一台时,就会出现这个错误

[2018-08-30 08:51:48,824] WARN [Consumer clientId=consumer-1, groupId=console-consumer-51176] Connection to node 2147483646 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2018-08-30 08:51:49,044] WARN [Consumer clientId=consumer-1, groupId=console-consumer-51176] Connection to node 2147483646 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2018-08-30 08:51:49,151] WARN [Consumer clientId=consumer-1, groupId=console-consumer-51176] Connection to node 1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2018-08-30 08:52:14,004] ERROR [Consumer clientId=consumer-1, groupId=console-consumer-51176] Offset commit failed on partition test3-0 at offset 29: This is not the correct coordinator. (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2018-08-30 08:52:14,115] ERROR [Consumer clientId=consumer-1, groupId=console-consumer-51176] Offset commit failed on partition test3-0 at offset 29: This is not the correct coordinator. (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)
[2018-08-30 08:52:14,224] ERROR [Consumer clientId=consumer-1, groupId=console-consumer-51176] Offset commit failed on partition test3-0 at offset 29: The coordinator is loading and hence can't process requests. (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)

标签: apache

解决方案


推荐阅读