kafka查看监控消费情况

kafka | 2021-07-16 11:02:25

kafka监控，查看消费情况就可以了，有不断的消费说明状态正常的

1.查看所有消费者组
kafka-consumer-groups.sh --bootstrap-server 192.168.1.13:9092 --list

2.查看组的消费情况
kafka-consumer-groups.sh --describe --bootstrap-server 192.168.1.13:9092 --group transport-node-4a11b8dc6a4b

GROUP                       TOPIC                                   PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG             CONSUMER-ID                                                                   HOST            CLIENT-ID
transport-node-4a11b8dc6a4b tb_transport.notifications.4a11b8dc6a4b 0          4766            4766            0               transport-api-notifications-4a11b8dc6a4b-21a94ddc-9ff6-499d-acfe-b04563bcdfe0 /192.168.1.4    transport-api-notifications-4a11b8dc6a4b
transport-node-4a11b8dc6a4b tb_transport.api.responses.4a11b8dc6a4b 0          4954            4954            0               transport-api-response-4a11b8dc6a4b-fddaec90-b35c-4e77-b291-5da9b60dacbd      /192.168.1.4    transport-api-response-4a11b8dc6a4b

TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
topic名字分区id 当前已消费的条数总条数未消费的条数消费id 主机ip 客户端

登录后即可回复登录 | 注册

消息中间件rocketmq kafka activemq rabbitmq zeromq对比选型 kafka错误警告warn error while fetching metadata with correlation id 1 linux java cpu 内存占用过高情况排查 phoenix 查看表主键和字段信息的命令 spark streaming kafka 开发案例与环境配置 kafka集群环境配置安装搭建 spring kafkatemplate 实现 kafka 发送接受消息案例代码 hadoop 修改参数后刷新查看配置如何解决kafka 异常 no resolvable bootstrap urls given in bootstrap.servers kafka 控制台生产发送消息测试命令 phoenix如何查看表的主键信息 hdfs fsck命令操作查看block文件块信息 linux yum 安装、卸载、查看软件 mysql 校对确定较为复杂的一些特殊情况 mysql 11的变更情况 mysql 12的变更情况 windows查看端口占用及杀掉进程的方法 Kafka ack消费确认-提交和偏移量详解 kafka彻底删除topic kafka查看监控消费情况