flink-状态一致性

相当于Haspmap.push(key,value) key和value一样,怎么写入都不变 flink超时默认是1小时,kafka默认15分钟,所以一致性的时候超时时间必须要处理一致。否则会造成数据丢失。
相关文章
相关标签/搜索