希望统计flink sql作业延迟,包括以下三个指标:
1. kafka消息延迟 (消息进到kafka时间 - 消息事件本身发生时间)
2. flink作业本身延迟 (消息处理完时间 - 消息开始处理时间)
3. 端到端延迟 (消息处理完时间 - 消息事件本身发生时间)


目前Flink 1.13.2是不是只能通过LatencyMarker获取到flink作业本身延迟? 开启的话会有性能影响吗?
据说Flink 1.14 新的source/sink api能够暴露一些metrics,但不清楚要具体怎么使用?谢谢!

回复