flink-狀態一致性

相當於Haspmap.push(key,value) key和value一樣,怎麼寫入都不變 flink超時默認是1小時,kafka默認15分鐘,所以一致性的時候超時時間必須要處理一致。否則會造成數據丟失。
相關文章
相關標籤/搜索