卡夫卡基本設置創建主題和發送消息的錯誤消息

我想設置我的卡夫卡，但我有一些關鍵問題。我甚至無法創建主題或發送消息。我的卡夫卡版本號是：0.9.0.1 感謝您的幫助。卡夫卡基本設置創建主題和發送消息的錯誤消息

下面請找我的錯誤信息：

[2016-04-21 04:41:19,306] producer ERROR LEADER_NOT_AVAILABLE 
Traceback (most recent call last): 
    File "", line 38, in <module> 
    producer.send_messages('abc.incoming_urls', json.dumps({'appid': 'channels', 'crawlid': 'category-%s' % (category), 'spiderid': 'abc', 'url': url, 'useragent': 'News/5.1.1 (iPhone; iOS 9.2; Scale/3.00)', 'attrs': {'id': category, '_': datetime.utcnow().isoformat()}})) 
    File "C:\Python27\lib\site-packages\kafka\producer\simple.py", line 52, in send_messages 
    partition = self._next_partition(topic) 
    File "C:\Python27\lib\site-packages\kafka\producer\simple.py", line 36, in _next_partition 
    self.client.load_metadata_for_topics(topic) 
    File "C:\Python27\lib\site-packages\kafka\client.py", line 505, in load_metadata_for_topics 
    kafka.common.check_error(topic_metadata) 
    File "C:\Python27\lib\site-packages\kafka\common.py", line 255, in check_error 
    raise error_class(response) 
LeaderNotAvailableError: TopicMetadata(topic='abc.incoming_urls', error=5, partitions=[])

來源

2016-04-21 peter

請問您可以添加一些更多的細節？像哪個命令給你這個錯誤？你的Kafka集羣是怎樣的？多少個經紀人？ Zookeeper conf？ – daemon12

小心在server.properties的advertised.host.name參數可能在飼養員登記不正確的主機名和阻止傳入的連接。

< #advertised.host.name=<hostname routable by clients> 
--- 
> advertised.host.name=xxx

來源

2016-04-27 13:45:52

卡夫卡基本設置創建主題和發送消息的錯誤消息

回答

相關問題