原因
之前服务器ip地址是动态的,后来改为静态ip地址后,kafka的一些配置都做了调整,导致我原来server.properties里的broker.id跟kafka日志目录下的meta.properties里的broker.id不一致。
解决办法
将meta.properties里的broker.id改为跟server.properties里的一致。因为kakfa产生日志会记录broker.id。
版权声明:本文为fu123123fu原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。