常用指令:
//新建虛擬視窗 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 網路斷開等方法.說明 如果無法確定採用何種命令安裝,可...