建立主題

$> bin/kafka-topics.sh --create --zookeeper hadoop05:2181 \
 --replication-factor 3 --partitions 3 --topic test

檢視主題列表

$> bin/kafka-topics.sh --list --zookeeper hadoop05:2181

檢視某個主題詳情

$> bin/kafka-topics.sh --topic test --describe --zookeeper hadoop05:2181

刪除主題

$> bin/kafka-topics.sh --delete --zookeeper hadoop05:2181 --topic test
 

注意：需要server.properties中設定delete.topic.enable=true否則只是標記刪除或者直接重啟

控制檯啟動生產者

$>bin/kafka-console-producer.sh --broker-list hadoop01:9092 --topic test

控制檯啟動消費者

$>bin/kafka-console-consumer.sh --bootstrap-server hadoop01:9092 --topic test  \ 
--from-beginning --zookeeper hadoop05:2181

檢視消費位置

$>
 
 bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker \ 
--zookeeper hadoop05:2181 --group testGroup

修改分割槽數

$> bin/kafka-topics.sh --zookeeper  hadoop05:2181 --alter --partitions 15 --topic   utopic