創(chuàng)建Topic

創(chuàng)新互聯(lián)堅持“要么做到，要么別承諾”的工作理念，服務領域包括：網(wǎng)站設計、成都網(wǎng)站制作、企業(yè)官網(wǎng)、英文網(wǎng)站、手機端網(wǎng)站、網(wǎng)站推廣等服務，滿足客戶于互聯(lián)網(wǎng)時代的尖山網(wǎng)站設計、移動媒體設計的需求，幫助企業(yè)找到有效的互聯(lián)網(wǎng)解決方案。努力成為您成熟可靠的網(wǎng)絡建設合作伙伴！

kafka-topics.sh --create --bootstrap-server localhost:9092 --topic abtest  --partitions 2 --replication-factor 1

查看Topic都有哪些

kafka-topics.sh --list --zookeeper localhost:2181

生產(chǎn)者，將文件中的數(shù)據(jù)寫入Kafka生產(chǎn)者

kafka-console-producer.sh --broker-list localhost:9092 --topic order_topic < abc.txt

消費者，從最開始的位移，消費Topic中的數(shù)據(jù)

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic order_topic  --from-beginning

重置Consumer Group的Offset到最新位移

kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group group_name_1 --reset-offsets --topic order_topic --to-latest --execute

查看消費者組Consumer Group位移

[homework@test ~]$ kafka-consumer-groups.sh --bootstrap-server  host1:9092,host2:9092  --describe --group groupname_1

TOPIC                 PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG             CONSUMER-ID     HOST            CLIENT-ID

order                 5          20781271        20781556        285             -               -               -
order                 1          10553765        10554032        267             -               -               -
order                 2          10634508        10634808        300             -               -               -
order                 7          10375128        10375355        227             -               -               -
order                 6          10435147        10435467        320             -               -               -
order                 0          10640342        10640643        301             -               -               -
order                 3          13762141        13762478        337             -               -               -
order                 8          11176468        11176707        239             -               -               -
order                 4          10443088        10443320        232             -               -               -

另外有需要云服務器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內外云服務器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務器、裸金屬服務器、高防服務器、香港服務器、美國服務器、虛擬主機、免備案服務器”等云主機租用服務以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務可用性高、性價比高”等特點與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應用場景需求。

網(wǎng)頁題目：【Kafka】常用命令-創(chuàng)新互聯(lián)
本文來源：http://m.rwnh.cn/article46/cspjhg.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供外貿網(wǎng)站建設、微信小程序、Google、微信公眾號、品牌網(wǎng)站建設、小程序開發(fā)

廣告

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