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 不知道什麼緣由就會致使部分分區不可用,用這個命令能夠查看。方法

相關文章
相關標籤/搜索