Flink实战（七十二）：监控（四）自定义metrics相关指标（二）

本文主要是介绍Flink实战（七十二）：监控（四）自定义metrics相关指标（二），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

项目实现代码举例：

添加自定义监控指标，以flink1.5的Kafka读取以及写入为例，添加rps、dirtyData等相关指标信息。�kafka读取和写入重点是先拿到RuntimeContex初始化指标，并传递给要使用的序列类，通过重写序列化和反序列化方法，来更新指标信息。

不加指标的kafka数据读取、写入Demo。

public class FlinkEtlTest {private static final Logger logger = LoggerFactory.getLogger(FlinkEtlTest.class);public static void main(String[] args) throws Exception {final ParameterTool params = ParameterTool.fromArgs(args);String jobName = params.get("jobName");StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

这篇关于Flink实战（七十二）：监控（四）自定义metrics相关指标（二）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---