kafka學習筆記 常用指令

2021-10-05 05:32:06 字數 1008 閱讀 4849

常用指令:

//新建虛擬視窗 kafka,在每台上執行

$ screen -s kafka

// 退出虛擬視窗 kafka,在每台上執行 $ ctrl+a+d

1.// 建立 topic

$ kafka-topics.sh --create --zookeeper cluster1:2181,cluster2:2181,cluster3:2181 --replication-factor 3 --partitions 1 --topic mykafka

2.// 檢視 topic:

$ kafka-topics.sh --list --zookeeper cluster1:2181,cluster2:2181,cluster3:2181(此時會顯示 topic:mykafka)

3.// 檢視詳細資訊

$ kafka-topics.sh --describe --zookeeper cluster1:2181,cluster2:2181,cluster3:2181

4.// 傳送訊息(cluster1 上執行)

$ kafka-console-producer.sh --broker-list localhost:9092 --topic mykafka

5.// 接收訊息(cluster2 上執行)

$ kafka-console-consumer.sh -zookeeper cluster1:2181,cluster2:2181,cluster3:2181 --topic mykafka --from-beginning

// 在 cluster1 輸入以下內容

test

mycluster test

可以在 cluster2 上看到相應的資訊。

按 ctrl+c 退出。

6.刪除話題mykafka

$ kafka-topics.sh --delete --zookeeper cluster1:2181,cluster2:2181,cluster3:2181 --topic mykafka

kafka常用指令總結

1 kafka官網 downloads 3 客戶端庫 4 librdkafka庫 二 kafka 版本0.9後的變更及瓶頸 1 服務端增加了groupcoordinator這個角色 2 topic的offset資訊由之前儲存在zk上改為儲存在乙個特殊的topic consumer offsets 中...

Linux學習筆記 ,常用指令

man 命令或配置檔案 功能描述 獲得幫助資訊 help 命令 功能描述 獲得shell內建命令的幫助資訊 pwd 功能描述 顯示當前工作目錄的絕對路徑 ls 選項 目錄或是檔案 a 顯示當前目錄所有的檔案和目錄,包括隱藏的 檔名以.開頭就是隱藏 l 以列表的方式顯示資訊 h 顯示檔案大小時,以 k...

學習筆記 ADB常用指令

adb devices 說明 正常顯示狀態應該是ip port state.state device說明裝置已經連線到計算機,state offline說明裝置沒有連線到計算機或無響應,這就需要嘗試重啟計算機 重啟android裝置 重啟adb 網路斷開等方法.說明 如果無法確定採用何種命令安裝,可...