你可以使用启动方式为:latest-offset
,此回答整理自钉群“【③群】Apache Flink China社区”