Kafka命令行操作
1）查看當前服務器中的所有topic
[sea@hadoop002 kafka]$ bin/kafka-topics.sh --zookeeper hadoop002:2181 --list
2）創建topic
[sea@hadoop002 kafka]$ bin/kafka-topics.sh --zookeeper hadoop002:2181 --create --replication-factor 3 --partitions 1 --topic first
選項說明：
--topic 定義topic名
--replication-factor 定義副本數
--partitions 定義分區數
3）刪除topic
[sea@hadoop002 kafka]$ bin/kafka-topics.sh --zookeeper hadoop002:2181 --delete --topic first
需要server.properties中設置delete.topic.enable=true否則只是標記刪除或者直接重啟。
4）發送消息
[sea@hadoop002 kafka]$ bin/kafka-console-producer.sh --broker-list hadoop002:9092 --topic first
>hello world
>sea sea
5）消費消息
[sea@hadoop103 kafka]$ bin/kafka-console-consumer.sh --zookeeper hadoop002:2181 --from-beginning --topic first
--from-beginning：會把first主題中以往所有的數據都讀取出來。根據業務場景選擇是否增加該配置。
6）查看某個Topic的詳情
[sea@hadoop002 kafka]$ bin/kafka-topics.sh --zookeeper hadoop002:2181 --describe --topic first