1 主題命令行操作

1. 查看操作主題命令參數(shù)

   

   創(chuàng)新互聯(lián)建站專業(yè)IDC數(shù)據(jù)服務(wù)器托管提供商，專業(yè)提供成都服務(wù)器托管，服務(wù)器租用，資陽托管服務(wù)器，資陽托管服務(wù)器，成都多線服務(wù)器托管等服務(wù)器托管服務(wù)。

   [azula@hadoop102 kafka]$ bin/kafka-topics.sh

   參數(shù)	描述
   –bootstrap-server	連接的 Kafka Broker 主機(jī)名稱和端口號(hào)。
   –topic	操作的 topic 名稱。
   –create	創(chuàng)建主題。
   –delete	刪除主題。
   –alter	修改主題。
   –list	查看所有主題。
   –describe	查看主題詳細(xì)描述。
   –partitions	設(shè)置分區(qū)數(shù)。
   –replication-factor	設(shè)置分區(qū)副本。
   –config	更新系統(tǒng)默認(rèn)的配置。

2. 查看當(dāng)前服務(wù)器中的所有 topic

   [azula@hadoop102 kafka]$ bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --list

3. 創(chuàng)建first topic

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

   選項(xiàng)說明：
   –topic 定義topic 名
   –replication-factor 定義副本數(shù)
   –partitions 定義分區(qū)數(shù)

4. 查看first 主題的詳情

   [azula@hadoop102 kafka]$ bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --describe --topic first

5. 修改分區(qū)數(shù)（注意：分區(qū)數(shù)只能增加，不能減少）

   [azula@hadoop102 kafka]$ bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --alter --topic first --partitions 3

6. 再次查看first 主題的詳情

   [azula@hadoop102 kafka]$ bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --describe --topic first

7. 刪除topic

   [azula@hadoop102 kafka]$ bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --delete --topic first

2 生產(chǎn)者命令行操作

1. 查看操作生產(chǎn)者命令參數(shù)

   [azula@hadoop102 kafka]$ bin/kafka-console-producer.sh

   參數(shù)	描述
   –bootstrap-server	連接的 Kafka Broker 主機(jī)名稱和端口號(hào)。
   –topic	操作的 topic 名稱。

2. 發(fā)送消息

   [azula@hadoop102 kafka]$ bin/kafka-console-producer.sh --bootstrap-server hadoop102:9092 --topic first 
   >hello world 
   >azula  azula

3 消費(fèi)者命令行操作

1. 查看操作消費(fèi)者命令參數(shù)

   [azula@hadoop102 kafka]$ bin/kafka-console-consumer.sh

   參數(shù)	描述
   –bootstrap-server	連接的 Kafka Broker 主機(jī)名稱和端口號(hào)。
   –topic	操作的 topic 名稱。
   –from-beginning	從頭開始消費(fèi)。
   –group	指定消費(fèi)者組名稱。

2. 消費(fèi)消息

   • 消費(fèi)first 主題中的數(shù)據(jù)。

     [azula@hadoop102 kafka]$ bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --topic first

   • 把主題中所有的數(shù)據(jù)都讀取出來（包括歷史數(shù)據(jù)）。

     [azula@hadoop102 kafka]$ bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --from-beginning --topic first

你是否還在尋找穩(wěn)定的海外服務(wù)器提供商？創(chuàng)新互聯(lián)www.cdcxhl.cn海外機(jī)房具備T級(jí)流量清洗系統(tǒng)配攻擊溯源，準(zhǔn)確流量調(diào)度確保服務(wù)器高可用性，企業(yè)級(jí)服務(wù)器適合批量采購，新人活動(dòng)首月15元起，快前往官網(wǎng)查看詳情吧

網(wǎng)頁名稱：Kafka命令行操作-創(chuàng)新互聯(lián)
URL分享：http://www.rwnh.cn/article36/gegsg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供云服務(wù)器、搜索引擎優(yōu)化、商城網(wǎng)站、微信公眾號(hào)、網(wǎng)站策劃、網(wǎng)站內(nèi)鏈

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)