Kafka經常使用命令

Kafka的bin目錄下有許多腳本，方便使用，例如與主題相關的kafka-topics.sh 腳本，這裏假設kafka在zookeeper上的根目錄爲/kafka1

1.查看主題：

sh kafka-topics.sh --list --zookeeper zk_ip1:2181,zk_ip2:2181,zk_ip3:2181/kafka1

2.建立主題：

sh kafka-topic.sh --create --partitions 2 --replication-factor 2 --zookeeper zk_ip:2181/kafka1  --topic Customer //建立主題Customer,含有兩個分區，分區副本數爲2

3.刪除主題：

sh kafka-topics.sh --zookeeper zk_ip1:2181,zk_ip2:2181,zk_ip3:2181/kafka1 --delete --topic Customer

4.進入zookeeper，查看kafka相關目錄：

sh zookeeper-shell.sh zk_ip:2181 ls /kafka1
get /kafka1/brokers/ids/2 

 5. 控制檯打印主題中的消息

sh kafka-console-consumer.sh --zookeeper ip1:2181,ip2:2181,ip3:2181/kafka1 --topic Demo1 --from-beginning