设置从指定offset开始读取 在Flink 1.3.0及以上可以使用setStartFromSpecificOffsets设置从指定offset开始读取 Fault Tolerance 开启checkpoint即可 offset提交行为 如果checkpoint被禁用,F...

Continue reading