1）查看操作主題命令參數(shù)
[ubuntu@hadoop kafka]$ bin/kafka-topics.sh

參數(shù)	描述
--bootstrap-server	連接的KafkaBroker主機名稱和端口號。
--topic	操作的topic名稱。
--create	創(chuàng)建主題。
--delete	刪除主題。
--alter	修改主題。
--list	查看所有主題。
--describe	查看主題詳細描述。
--partitions	設(shè)置分區(qū)數(shù)。
--replication-factor	設(shè)置分區(qū)副本。
--config	更新系統(tǒng)默認的配置。

2）查看當(dāng)前服務(wù)器中的所有 topic
[ubuntu@hadoop kafka]$ bin/kafka-topics.sh --bootstrap-server hadoop:9092 --list

3）創(chuàng)建 first topic
[ubuntu@hadoop kafka]$ bin/kafka-topics.sh --bootstrap-server hadoop:9092 --create --partitions 1 --replication-factor 3 --topic first

4）查看 first 主題的詳情
[ubuntu@hadoop kafka]$ bin/kafka-topics.sh --bootstrap-server hadoop:9092 --describe --topic first

5）修改分區(qū)數(shù)（注意：分區(qū)數(shù)只能增加，不能減少）
[ubuntu@hadoop kafka]$ bin/kafka-topics.sh --bootstrap-server hadoop:9092 --alter --topic first --partitions 3

6）再次查看 first 主題的詳情
[ubuntu@hadoop kafka]$ bin/kafka-topics.sh --bootstrap-server hadoop:9092 --describe --topic first

7）刪除 topic（學(xué)生自己演示）
[ubuntu@hadoop kafka]$ bin/kafka-topics.sh --bootstrap-server hadoop:9092 --delete --topic first
?

生產(chǎn)者命令行操作

1）查看操作生產(chǎn)者命令參數(shù)
[ubuntu@hadoop kafka]$ bin/kafka-console-producer.sh

參數(shù)	描述
--bootstrap-server	連接的 Kafka Broker 主機名稱和端口號。
--topic	操作的 topic 名稱。

2）發(fā)送消息
[ubuntu@hadoop kafka]$ bin/kafka-console-producer.sh --bootstrap-server hadoop:9092 --topic first
>hello world

消費者命令行操作

1）查看操作消費者命令參數(shù)
[ubuntu@hadoop kafka]$ bin/kafka-console-consumer.sh

參數(shù)	描述
--bootstrap-server	連接的 Kafka Broker 主機名稱和端口號。
--topic	操作的 topic 名稱。
--from-beginning	從頭開始消費。
--group	指定消費者組名稱。

2）消費消息

（1）消費first主題中的數(shù)據(jù)。
[ubuntu@hadoop kafka]$ bin/kafka-console-consumer.sh --bootstrap-server hadoop:9092 --topic first

（2）把主題中所有的數(shù)據(jù)都讀取出來（包括歷史數(shù)據(jù)）。
[ubuntu@hadoop kafka]$ bin/kafka-console-consumer.sh --bootstrap-server hadoop:9092 --from-beginning --topic first