創(chuàng)建topic

蕪湖縣網(wǎng)站制作公司哪家好，找創(chuàng)新互聯(lián)公司！從網(wǎng)頁設計、網(wǎng)站建設、微信開發(fā)、APP開發(fā)、響應式網(wǎng)站設計等網(wǎng)站項目制作，到程序開發(fā)，運營維護。創(chuàng)新互聯(lián)公司2013年開創(chuàng)至今到現(xiàn)在10年的時間，我們擁有了豐富的建站經(jīng)驗和運維經(jīng)驗，來保證我們的工作的順利進行。專注于網(wǎng)站建設就選創(chuàng)新互聯(lián)公司。

kafka-topics --create --zookeeper master:2181/kafka2 --replication-factor 2 --partitions 3 --topic mydemo5

列出topic

kafka-topics --list --zookeeper master:2181/kafka2

描述topic

kafka-topics --describe --zookeeper master:2181/kafka2 --topic mydemo5

生產(chǎn)者生產(chǎn)消息

kafka-console-producer --broker-list master:9092 --topic mydemo5

消費者消費消息指定消費組名

kafka-console-consumer --bootstrap-server master:9092,node01:9092,node02:9092 --new-consumer --consumer-property group.id=test_kafka_game_x_g1 --topic mydemo5

查看正在運行的消費組

kafka-consumer-groups --bootstrap-server master:9092 --list --new-consumer

計算消息的消息堆積情況

kafka-consumer-groups --bootstrap-server master:9092 --describe --group  test_kafka_game_x_g1

####詳細說明
LogEndOffset 下一條將要被加入到日志的消息的位移
CurrentOffset 當前消費的位移
LAG 消息堆積量

消息堆積量：消息中間件服務端中所留存的消息與消費掉的消息之間的差值即為消息堆積量也稱之為消費滯后量

LogEndOffset：代表Partition的最高日志位移。簡稱LEO

消息發(fā)送到LeaderA之后會更新LEO的值，F(xiàn)ollowerB和FllowerC也會實時拉取LeaderA中的消息來更新自己，HW就表示A、B、C三者同時達到的日志位移。也就是A、B、C三者中LEO最小的那個值。由于B、C拉取A消息之間延時問題，所有HW必然不會與Leader的LEO相等，即LEO>=HW

參考
https://blog.csdn.net/u013256816/article/details/79955578

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

標題名稱：查看kafka消息隊列的積壓情況-創(chuàng)新互聯(lián)
網(wǎng)站路徑：http://www.chinadenli.net/article44/desihe.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供建站公司、外貿(mào)建站、網(wǎng)站建設、Google、營銷型網(wǎng)站建設、定制開發(fā)

廣告

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