十二、Kafka

（1）Topic

1）檢視當前伺服器中的所有topic

bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --list

2）建立first topic

bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --create --partitions 1 --replication-factor 3 --topic first

引數說明

--topic 定義 topic 名
--replication-factor 定義副本數
--partitions 定義分割槽數

3）檢視first主題詳情

bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --describe --topic first

4）修改分割槽數（只可以增加不可以減少）

bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --alter --topic first --partitions 3

5）刪除topic

bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --delete --topic first

（2）生產者

傳送訊息

bin/kafka-console-producer.sh --bootstrap-server hadoop102:9092 --topic first

引數描述
--bootstrap-server <String: server toconnect to> 連線的 Kafka Broker主機名稱和埠號。
--topic <String: topic> 操作的 topic名稱。

（3）消費者

1）消費主題first中的資料

bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --topic first

引數 描述
--bootstrap-server <String: server toconnect to> 連線的 Kafka Broker主機名稱和埠號。
--topic <String: topic> 操作的 topic名稱。

--from-beginning 從頭開始消費。
--group <String: consumer group id> 指定消費者組名稱。

2）把主題中的資料都讀取出來（包括歷史資料）

bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --from-beginning --topic first