Kafka命令行操作-創(chuàng)新互聯(lián)

1 主題命令行操作

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

    創(chuàng)新互聯(lián)建站專業(yè)IDC數(shù)據(jù)服務(wù)器托管提供商，專業(yè)提供成都服務(wù)器托管，服務(wù)器租用，資陽(yáng)托管服務(wù)器，資陽(yáng)托管服務(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)說(shuō)明：
    –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從頭開(kāi)始消費(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ù)都讀取出來(lái)（包括歷史數(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ù)器適合批量采購(gòu)，新人活動(dòng)首月15元起，快前往官網(wǎng)查看詳情吧

網(wǎng)頁(yè)名稱：Kafka命令行操作-創(chuàng)新互聯(lián)
URL分享：http://bm7419.com/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í)需注明來(lái)源： 創(chuàng)新互聯(lián)

h5響應(yīng)式網(wǎng)站建設(shè)