Shulou(Shulou.com)06/03 Report--

Create topic

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

List topic

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

Describe topic

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

Producer production news

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

Consumer consumption message specifies the consumer group name

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

View running consumption groups

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

Calculate the message accumulation of messages

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

# details

The displacement of the LogEndOffset's next message to be added to the log

The shift of CurrentOffset's current consumption

Volume of LAG message accumulation

Message accumulation: the difference between the messages retained in the message middleware server and the messages consumed is the message accumulation, also known as consumption lag.

LogEndOffset: represents the highest log offset of Partition. Abbreviated as LEO

After the message is sent to LeaderA, the value of LEO will be updated, and FollowerB and FllowerC will also pull the message in LeaderA to update themselves in real time. HW represents the log offset reached by A, B and C at the same time. That is, the smallest value of LEO among A, B and C. Because of the delay between B and C pulling A messages, all HW must not be equal to the LEO of Leader, that is, LEO > = HW

Referenc

Https://blog.csdn.net/u013256816/article/details/79955578

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.