建站
咨詢
售后
建站咨詢
新聞中心
創(chuàng)建topic
成都創(chuàng)新互聯(lián)公司網(wǎng)絡(luò)公司擁有10余年的成都網(wǎng)站開發(fā)建設(shè)經(jīng)驗(yàn)，上千客戶的共同信賴。提供成都網(wǎng)站制作、做網(wǎng)站、網(wǎng)站開發(fā)、網(wǎng)站定制、外鏈、建網(wǎng)站、網(wǎng)站搭建、自適應(yīng)網(wǎng)站建設(shè)、網(wǎng)頁(yè)設(shè)計(jì)師打造企業(yè)風(fēng)格，提供周到的售前咨詢和貼心的售后服務(wù)
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消費(fèi)者消費(fèi)消息指定消費(fèi)組名
kafka-console-consumer --bootstrap-server master:9092,node01:9092,node02:9092 --new-consumer --consumer-property group.id=test_kafka_game_x_g1 --topic mydemo5查看正在運(yùn)行的消費(fèi)組
kafka-consumer-groups --bootstrap-server master:9092 --list --new-consumer 
計(jì)算消息的消息堆積情況
kafka-consumer-groups --bootstrap-server master:9092 --describe --group test_kafka_game_x_g1
####詳細(xì)說明
LogEndOffset 下一條將要被加入到日志的消息的位移
CurrentOffset 當(dāng)前消費(fèi)的位移
LAG 消息堆積量
消息堆積量：消息中間件服務(wù)端中所留存的消息與消費(fèi)掉的消息之間的差值即為消息堆積量也稱之為消費(fèi)滯后量
LogEndOffset：代表Partition的最高日志位移。簡(jiǎn)稱LEO
消息發(fā)送到LeaderA之后會(huì)更新LEO的值，F(xiàn)ollowerB和FllowerC也會(huì)實(shí)時(shí)拉取LeaderA中的消息來更新自己，HW就表示A、B、C三者同時(shí)達(dá)到的日志位移。也就是A、B、C三者中LEO最小的那個(gè)值。由于B、C拉取A消息之間延時(shí)問題，所有HW必然不會(huì)與Leader的LEO相等，即LEO>=HW
參考
https://blog.csdn.net/u013256816/article/details/79955578
網(wǎng)站欄目：查看kafka消息隊(duì)列的積壓情況
本文URL：http://fisionsoft.com.cn/article/pocjie.html
