創(chuàng)建topic

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

####詳細(xì)說明

LogEndOffset 下一條將要被加入到日志的消息的位移

CurrentOffset 當(dāng)前消費的位移

LAG 消息堆積量

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

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

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

總結(jié)

以上是生活随笔為你收集整理的linux查看数据积压,查看kafka消息队列的积压情况的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。