文章目录

1.概述1.1 查看消费组1.2 检测topic1.3 内置topic1.4 flink数据监控1.5 提交offset指标 M.扩展

1.概述

一个环境，突然发现，Flink消费kafka，只有一个分区不消费了，延迟特别大，其他的分区正常。

1.1 查看消费组

[root@1 kafka]# bin/