Flink基于Kafka-Connector 数据流容错回放机制

转载自：https://blog.csdn.net/shenshouniu/article/details/84558874java 你可能感兴趣的文章： 1-Flink入门 2-本地环境搭建&构建第一个Flink应用 3-DataSet API 4-DataSteam API 5-集群部署 6-分布式缓存 7-重启策略 8-Flink中的窗口 9-Flink中的Time Flink时间戳和水印

>>阅读原文<<