天天看點

Kafka-shell常用操作

kafka 的shell操作(基于topic的增删改查 shell)

目錄

1. 啟動節點的Kafka程序

2. 建立topic

3. 檢視已建立的所有topics

4. 檢視指定topic詳細資訊

5. 開啟生産者模式

6. 開啟消費者模式

7. 檢視分區偏移量

8. 增加topic分區數

9. 删除topic

10. 檢視隊列資訊

11. 檢視指定隊列消費資料

CDH已經啟動可以忽略

新版本,consumer 資訊存儲在 Kafka 的 broker 中,Kafka自維護偏移量,。

舊版本,consumer 資訊存儲在 Zookeeper 中,Zookeeper 維護偏移量。