项目实现代码举例: 添加自定义监控指标,以flink1.5的Kafka读取以及写入为例,添加rps、dirtyData等相关指标信息。�kafka读取和写入重点是先拿到RuntimeContex初始化指标,并传递给要使用的序列类,通过重写序列化和反序列化方法,来更新指标信息。 不加指标的kafka数据读取、写入Demo。 public class FlinkEtlTest {priv
大部分时候,我们都做着单线程的编程,前面所有程序都只有一条顺序执行流——程序从 main 方法开始执行,依次向下执行每行代码,如果程序执行某行代码时遇到了阻塞,则程序将会停滞在该处。如果我们使用 IDE 工具的单步调试功能,就可以非常清楚地看出这一点。 但实际的情况是,单线程的程序往往功能非常有限,例如,我们开发一个简单的服务器程序,这个服务器程序需要向不同的客户端提供服务时,不同的客户端之间应