Kafka 查询

进入Kafka安装目录。

执行以下命令：

bin/kafka-consumer-groups.sh --bootstrap-server ip:9092 --list

执行以下命令：

bin/kafka-consumer-groups.sh --bootstrap-server ip:9092 --group 消费组名 --describe

• current_offset：当前已消费数
• Log-end-offset: topic 分区总消息数据
• Lag: 未消费数据
  • 为0表示已消费完成
  • 在增大证明同步软件推送数据到Kafka速率大于Kafka数据被消费速率
  • 在减少证明推送至Kafka的数据在被正常消费

执行以下命令：

bin/kafka-consumer-groups.sh --bootstrap-server ip:9092 --group 消费组名 --describe |sort -k 1 |grep 小写表名

主要查看指定表名消费情况：Log-end-offset current_offset Lag