java.lang.RuntimeException: A broker is already registered on the path /brokers/ids/102. 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.

翻译: 代理已经在路径/brokers/ids/1上注册。这可能表明您已经配置了一个已经在使用中的代理id,或者您已经关闭了该代理并以更快的速度重新启动了它

解决方案:zkCli.sh进入zookeeper客户端

[zk: localhost:2181(CONNECTED) 4] ls /brokers/ids    
[103, 104]

删除代理id

rmr /brokers/ids

deleteall /broker/ids

参考原文

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐