现象:刚搭建完集群之后,建立一个Topic,命令行提示创建成功,但是Kafka Server的日志一直报类似于如下错误:this server is not the leader for that topic-partition,LEADER_NOT_AVAILABLE 等信息,创建出来的topic无法消费,生产者也无法发送消息。
原因:host配置有问题,我在centos的host的配置文件中的127.0.0.1那一行中加入了主机名,然后就造成,zookeeper中记录的三个broker中,ubuntu的是主机名,两台centos记录的地址都是localhost,所以虽然三台机器的Kafka Server都成功运行起来了,但是实际起作用的只有ubuntu,所以创建topic的时候,只要replication-factor大于1,就肯定会出问题,等于1实测也会报错。
解决方案:修改host,127.0.0.1那一行中不要加入主机名。
另附2个有用的链接:kafka报错LEADER_NOT_AVAILABLE,kafka消费端测试错误怎么解决kafka.common.NotLeaderForPartitionException。