Kafka高级消费者error_code = 15

Question

当尝试使用高级消费者(使用全新的消费者群体)从Kafka消费时,消费者永远不会开始运行.当我将日志记录级别切换到调试时,我可以看到以下两行一遍又一遍地重复:

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.internals.ConsumerNetworkClient$RequestFutureCompletionHandler@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意味着组协调员不可用.我认为这意味着消费者组协调员.这是回调问题吗？为什么高级消费者无法工作？

Answer 1

事实证明,该__consumer_offsets主题的所有分区都位于死节点(我关闭的节点,永远不会返回).我通过关闭群集,__consumer_offsets从Zookeeper中删除主题然后再次启动群集来解决了这个问题.