启动kafaka失败了,提示zk保存kafka的ids已经在使用。

Posted xiongmozhou

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了启动kafaka失败了,提示zk保存kafka的ids已经在使用。相关的知识,希望对你有一定的参考价值。

FATAL [Kafka Server 1], Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
java.lang.RuntimeException: A broker is already registered on the path /brokers/ids/1. This probably indicates that you either have configured a brokerid that is already in use, or else you have shutdown this broker and restarted it faster than the zookeeper timeout so it appears to be re-registering.

 

原因:可能是kafka或者zookeeper不正常关闭引起的。

 

发现问题:kafka集群启动时,zk里面找不到该brokers_id,但是关闭kafka集群就可以发现这个brokers,我们只需要把ids这个节点删除就行,重新启动kafka,好了。

  1. [推荐]您需要清理zookeeper路径/ brokers / ids / []中的代理ID。使用zk-cli tool delete命令清除路径。启动您的代理并验证它是否向协调员注册。

  2. 解决此问题的另一种方法是从kafka服务器配置更改您的broker-id并重新启动代理。但是,这会破坏您的分区,不建议使用数据

 

其他情况:

https://blog.csdn.net/hello_world_qwp/article/details/79419532

以上是关于启动kafaka失败了,提示zk保存kafka的ids已经在使用。的主要内容,如果未能解决你的问题,请参考以下文章

Kafaka技术第一课

Kafaka入门(1)- Kafka简介和安装与启动(mac)

三、Kafaka的基本操作

如何将 Spark 消耗的最新偏移量保存到 ZK 或 Kafka 并在重启后可以读取

防火墙导致zookeeper集群异常,kafka起不来

脚本一键启动zk,kafka集群