在CDH上启动kafka命令 (如果cdh01后面不加端口号就是默认的zookeeper端口2181)
[root@cdh03 bin]# kafka-topics --create --zookeeper cdh01 --replication-factor 3 --partitions 3 --topic test4
报出以下错误 ——说没有broker可用
我们去集群里看一下
上面显示kafka的3个broker是OK的，接下来我们看一下kafka在CDH上的配置信息
原来是这里出了问题，装kafka时这里配置的Zookeeper Root目录为/kafka，而kafka创建topic默认的路径为/root，知道问题所在后我们就更改一下命令就OK了
[root@cdh03 bin]# kafka-topics --create --zookeeper cdh01/kafka --replication-factor 3 --partitions 3 --topic test4
这样就OK了