檢視當前伺服器中的所有topic：
bin/kafka-topics.sh --zookeeper 主機:2181 --list
建立topic：
bin/kafka-topics.sh --zookeeper 主機:2181 --create --replication-factor 3 --partitions 1 --topic 名
字刪除topic：
bin/kafka-topics.sh --zookeeper 主機:2181 --delete --topic 名字
需要server.properties中設定delete.topic.enable=true否則只是標記刪除。
傳送訊息：
bin/kafka-console-producer.sh --broker-list 主機:9092 --topic 名字
>hello world
消費訊息：
bin/kafka-console-consumer.sh --zookeeper 主機:9092 --topic 名字
bin/kafka-console-consumer.sh --bootstrap-server 主機:9092 --topic 名字
bin/kafka-console-consumer.sh --bootstrap-server 主機:9092 --from-beginning --topic 名字
檢視某個topic的情況
bin/kafka-topic.sh --zookeeper 主機:2181 --describe --topic 名字
修改分割槽數：
bin/kafka-topics.sh --zookeeper 主機:2181 --alter --topic 名字 --partitions 6
Kafka命令列操作
1 檢視當前伺服器中的所有topic atguigu hadoop102 kafka bin kafka topics.sh zookeeper hadoop102 2181 list2 建立topic atguigu hadoop102 kafka bin kafka topics.sh zook...
Kafka 命令列操作
1.檢視當前伺服器中的所有 topic bin kafka topics.sh zookeeper localhost 2181 list2.建立 topic bin kafka topics.sh zookeeper localhost 2181 create replication factor...
Kafka命令列操作
1.檢視當前伺服器中的所有topicbin kafka topics.sh zookeeper bigdata13 2181 list2.建立topicbin kafka topics.sh zookeeper bigdata13 2181 create replication factor 3 p...