在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来修复错误; 但是，我宁愿卡夫卡自动启动。

如何持续向kafka馈送嗅探包？

把Nginx日志放入Kafka最好的select？

在Windows上安装librdkafka以支持Python开发

尝试在Windows中启动Zookeeper时，“log4j.properties在这个时候是意外的”

在Windows中设置Kafka日志目录属性

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

Kafka – 无法使用Java将消息发送到远程服务器

当Kafka从Python脚本启动时，kafka-server-stop.sh不工作

Kafka无法在Windows上启动 – 没有find密钥： tmp kafka-logs

卡夫卡在没有docker的docker组成？

在Windows上安装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服务器时，错误消失了。