douzi9744 2018-03-26 11:53
浏览 1280
已采纳

kafka服务器:偏移的主题尚未创建

I'm using Kafka server 0.9 + zookeper. I'm new with Kafka. It's running in virtualbox , I can connect to it using public IP so it's working ... more or less: can get topics and messages. So for now I have 2 issues:

  1. I can't find anything at __consumer_offsets (empty) and that's why I've got issue with the go simple consumer script throwing error: kafka server: Offset's topic has not yet been created; when i check at zookeeper-shell.sh console by command ls /brokers/topics/__consumer_offsets it errors me : Node does not exist: /brokers/topics/__consumer_offsets

  2. (maybe they are connected) I've got minor warning when autocreating topic: WARN NetworkClient - Error while fetching metadata with correlation id 4157 : {topicName=LEADER_NOT_AVAILABLE}

Any help it highly appreciated. Thanks!

  • 写回答

2条回答 默认 最新

  • douduan5073 2018-03-26 13:50
    关注

    The reason was successfully found in logs : Number of alive brokers '1' does not meet the required replication factor '3' for the offsets topic you need to post into your server.properties file following option : offsets.topic.replication.factor=1. This option will not let you do anything till the count reaches 3 but since you have it set as a playbox - you usually have 1 only.

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(1条)

报告相同问题?

悬赏问题

  • ¥20 ML307A在使用AT命令连接EMQX平台的MQTT时被拒绝
  • ¥20 腾讯企业邮箱邮件可以恢复么
  • ¥15 有人知道怎么将自己的迁移策略布到edgecloudsim上使用吗?
  • ¥15 错误 LNK2001 无法解析的外部符号
  • ¥50 安装pyaudiokits失败
  • ¥15 计组这些题应该咋做呀
  • ¥60 更换迈创SOL6M4AE卡的时候,驱动要重新装才能使用,怎么解决?
  • ¥15 让node服务器有自动加载文件的功能
  • ¥15 jmeter脚本回放有的是对的有的是错的
  • ¥15 r语言蛋白组学相关问题