1.概述
1.1 查看消费组
1.2 检测topic
1.3 内置topic
1.4 flink数据监控
1.5 提交offset指标
M.扩展
一个环境,突然发现,Flink消费kafka,只有一个分区不消费了,延迟特别大,其他的分区正常。
1.1 查看消费组[root@1 kafka]# bin/

1.概述
1.1 查看消费组
1.2 检测topic
1.3 内置topic
1.4 flink数据监控
1.5 提交offset指标
M.扩展
一个环境,突然发现,Flink消费kafka,只有一个分区不消费了,延迟特别大,其他的分区正常。
1.1 查看消费组[root@1 kafka]# bin/