1付呕、創(chuàng)建topic
kafka-topics.sh
kafka-topics.sh --create --partitions 3 --replication-factor 2 --topic test --zookeeper node01:2181,node02:2181,node03:2181
2、查詢所有的topic
kafka-topics.sh
kafka-topics.sh --list --zookeeper node01:2181,node02:2181,node03:2181
3翠桦、查看topic的描述信息
kafka-tipics.sh
kafka-topics.sh --describe --topic test --zookeeper node01:2181,node02:2181,node03:2181
4十厢、刪除topic
kafka-topic.sh
kafka-topics.sh --delete --topic test --zookeeper node01:2181,node02:2181,node03:2181
5、模擬生產(chǎn)者寫入數(shù)據(jù)到topic中
kafka-console-producer.sh
kafka-console-producer.sh --broker-list node01:9092,node02:9092,node03:9092 --topic test
6爷耀、模擬消費者拉取topic中的數(shù)據(jù)
kafka-console-consumer.sh
kafka-console-consumer.sh --zookeeper node01:2181,node02:2181,node03:2181 --topic test --from--beginning
或者
kafka-console-consumer.sh --bootstrap-server node01:9092,node02:9092,node03:9092 --topic test --from-beginning
kafka的命令行的管理使用
最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
- 文/潘曉璐 我一進(jìn)店門窄做，熙熙樓的掌柜王于貴愁眉苦臉地迎上來，“玉大人慰技，你說我怎么就攤上這事椭盏。” “怎么了吻商？”我有些...
- 文/不壞的土叔 我叫張陵掏颊，是天一觀的道長。 經(jīng)常有香客問我艾帐，道長乌叶，這世上最難降的妖魔是什么？ 我笑而不...
- 正文 為了忘掉前任掩蛤，我火速辦了婚禮枉昏，結(jié)果婚禮上，老公的妹妹穿的比我還像新娘揍鸟。我一直安慰自己兄裂，他們只是感情好，可當(dāng)我...
- 文/花漫 我一把揭開白布阳藻。 她就那樣靜靜地躺著晰奖，像睡著了一般。 火紅的嫁衣襯著肌膚如雪腥泥。 梳的紋絲不亂的頭發(fā)上匾南，一...
- 文/蒼蘭香墨 我猛地睜開眼矛纹，長吁一口氣：“原來是場噩夢啊……” “哼臂聋！你這毒婦竟也來了？” 一聲冷哼從身側(cè)響起，我...
- 正文 年R本政府宣布，位于F島的核電站感局，受9級特大地震影響尼啡，放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜询微，卻給世界環(huán)境...
- 文/蒙蒙 一崖瞭、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧撑毛，春花似錦书聚、人聲如沸。這莊子的主人今日做“春日...
- 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至胯杭，卻和暖如春驯杜，著一層夾襖步出監(jiān)牢的瞬間，已是汗流浹背做个。 一陣腳步聲響...
推薦閱讀更多精彩內(nèi)容
- kafka安裝目錄下的bin目錄包含了很多運(yùn)維可操作的shell腳本，列舉如下： 接下來詳細(xì)說明每個腳本的使用方法...
- Flume 日志收集系統(tǒng) #安裝 在node01下 在hadoop用戶下 cd ~/apps 在此路徑下 解壓后是...
