在Linux重新启动后,Kafka抛出“尝试重新平衡时没有find中间商”

我遵循了在Linux上安装Kafka的一个很好的分步教程 。 一切工作正常,直到我重新启动Linux。 重新启动后,当我尝试使用kafka-console-consumer.sh队列时,出现以下错误。

 $ ~/kafka/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic TutorialTopic --from-beginning 

[2016-02-04 03:16:54,944]警告, 没有经纪人试图重新平衡时发现 。 (kafka.consumer.ZookeeperConsumerConnector)

在运行kafka-console-consumer.sh脚本之前,我使用kafka-console-consumer.sh脚本将数据推送到Kafka队列。 在重新启动Linux之前,这些步骤没有问题。

我可以通过手动启动Kafka来修复错误; 但是,我宁愿卡夫卡自动启动。

什么可能导致卡夫卡重新启动后无法正确启动?

所以我今天早些时候在我们的hortonworks集群中也遇到类似的问题。 看起来动物园管理员没有正确启动。 我第一次尝试kakfa控制台生产者,并得到了下面的例外:

 kafka-console-producer.sh --broker-list=localhost:9093 --topic=some_topic < /tmp/sometextfile.txt``` kafka.common.KafkaException: fetching topic metadata for topics``` 

我的解决方案是重新启动已停止响应的服务器。 你可能会有所不同,但与控制台制作人玩弄,看看你得到什么错误。

从/ tmp文件夹中删除与zookeeper和kafka相关的所有内容。为我工作。 但我的系统不是生产..所以对于其他人谨慎行事。

默认情况下,kafka将所有信息存储在/tmp文件夹中。 每次重新启动时,tmp文件夹都会被删除。 您可以通过在属性文件config/server.properties更改属性log.dirs来更改这些文件的位置。

对于我来说,当启动消费者从代理集群获取消息时。 但是Kafka服务器被关闭了。 所以,回复了“试图重新平衡时找不到经纪人”的信息。 当我重新启动kafka服务器时,错误消失了。