Kafka高级消费者error_code = 15

尝试使用高级消费者（使用全新的消费者群体）从卡夫卡消费时，消费者从不开始运行。当我切换日志级别调试，我可以看到下面的两行重复自己遍地：Kafka高级消费者error_code = 15

DEBUG [AbstractCoordinator] 09:43:51.192: Sending coordinator request for group CompletelyNewConsumerGroupThatIneverUsedBefore to broker 172.30.3.61:30000 (id: 1043 rack: null) 
DEBUG [AbstractCoordinator] 09:43:51.306: Received group coordinator response ClientResponse(receivedTimeMs=1487666631306, disconnected=false, request=ClientRequest(expectResponse=true, callback=org.apache.kafka.clients.consumer[email protected]58f68932, request=RequestSend(header={api_key=10,api_version=0,correlation_id=197,client_id=consumer-1}, body={group_id=CompletelyNewConsumerGroupThatIneverUsedBefore}), createdTimeMs=1487666631192, sendTimeMs=1487666631192), responseBody={error_code=15,coordinator={node_id=-1,host=,port=-1}})

群集的所有6个节点消耗的数据正常。即使是旧的低级别消费者的作品。另外在Zookeeper中只有6个节点应该在那里，他们的日志文件看起来不错。

从谷歌搜索我发现error_code = 15意味着组协调器不可用。我认为这意味着消费者团体的协调员。这是回调问题吗？为什么高级消费者不工作？

来源

2017-02-21 xgb84j

高层次消费者是老消费者。根据抛出的异常，您应该使用新的消费者，并且消费者抱怨找不到协调者。您是否使用经纪商自动生成的ID？ – amethystic

@amethystic，你好，请你指点我的文档说老顾客抱怨团队协调员？它对0.9.x有效吗？ – Novitoll

事实证明，__consumer_offsets主题的所有分区都位于死亡节点上（我关闭的节点不会再回来）。我通过关闭群集，从Zookeeper删除__consumer_offsets主题，然后再次启动群集来解决问题。

来源

2017-02-23 12:49:34 xgb84j

Kafka高级消费者error_code = 15

回答

相关问题