Kafka的版本间差异较大,下面是0.8.1的操作方法

首先cd到kafaka的bin目录下,操作kafka的工具都在这里呢。如果发现找不到,或者名字不对,说明kafka版本不对。

以topic是test为例子 --zookeeper 后的ip改成你们自己的

创建topic ./kafka-topics.sh --topic test --create --partitions 2 --replication-factor 1 --zookeeper 10.234.10.17:2181,10.234.10.20:2181 partitions 为分区数,0.8.1默认就是2 replication-factor:为复制因子,也就是副本数

查看所有topic ./kafka-topics.sh --list --zookeeper 10.234.10.17:2181,10.234.10.20:2181

删除topic ./kafka-topics.sh --topic test --delete --zookeeper 10.234.10.17:2181,10.234.10.20:2181

查看topic明细 ./kafka-topics.sh --topic test --describe --zookeeper 10.234.10.17:2181,10.234.10.20:2181

查看不可用分区 ./kafka-topics.sh --topic test --describe --unavailable-partitions --zookeeper 10.234.10.17:2181,10.234.10.20:2181 不知道什么原因就会导致部分分区不可用,用这个命令可以查看。

05-15 04:32