Kafka经常使用操做

Kafka的版本间差别较大,下面是0.8.1的操做方法工具

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

以topic是test为例子 --zookeeper 后的ip改为大家本身的kafka

建立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:为复制因子,也就是副本数it

查看全部topic ./kafka-topics.sh --list --zookeeper 10.234.10.17:2181,10.234.10.20:2181io

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

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

查看不可用分区 ./kafka-topics.sh --topic test --describe --unavailable-partitions --zookeeper 10.234.10.17:2181,10.234.10.20:2181 不知道什么缘由就会致使部分分区不可用,用这个命令能够查看。方法

相关文章
相关标签/搜索