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

回答

相關問題