相当于Haspmap.push(key,value) key和value一样,怎么写入都不变 flink超时默认是1小时,kafka默认15分钟,所以一致性的时候超时时间必须要处理一致。否则会造成数据丢失。 相关文章: 2021-12-24 2021-09-19 2022-03-02 2021-06-16 2021-12-29 2021-05-06 2021-07-28 2022-01-19