我遵循了在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服务器时,错误消失了。
总结以上是内存溢出为你收集整理的在Linux重新启动后,Kafka抛出“尝试重新平衡时没有find中间商”全部内容,希望文章能够帮你解决在Linux重新启动后,Kafka抛出“尝试重新平衡时没有find中间商”所遇到的程序开发问题。
如果觉得内存溢出网站内容还不错,欢迎将内存溢出网站推荐给程序员好友。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)