kafka的版本间差异较大，下面是0.8.1的操作方法 首先cd到kafaka的bin目录下，操作kafka的工具都在这里呢。如果发现找不到，或者名字不对，说明kafka版本不对。 以topic是test为例子 –zookeeper 后的ip改成你们自己的 创建topic ./kafka-topics.sh –topic t
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
不知道什么原因就会导致部分分区不可用，用这个命令可以查看。
原文地址：kafka0.8.1 常用操作, 感谢原作者分享。