今天部署了kafka集群,三台服务器,启动后,生产者发送数据,消费者接收数据的时候报错,INVALID_REPLICATION_FACTOR。
查了很多资料,说是要改kafka下config目录的server.properties,可能是副本数太小,反复折腾了这个好久,问题未得以解决。
今天早上突然想到查看一下kafka的状态,反复用jps查看,发现kafka的1号机已经启动,其余俩个服务器,kafka都没有启动,于是就去查kafka的配置文件server.properties,发现自己犯了一个大错,三台服务器的broker.id都是一样的,555~~~
解决:
于是把三台服务器的broker.id修改一下,重启kafka集群,生产者发送数据,消费者能正常接收了