可以参考下这个： https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/connectors/ kafka.html#kafka-consumers-offset-committing-behaviour-configuration
-----Original Message----- From: [email protected] <[email protected]> On Behalf Of 小学 生 Sent: 2020年7月30日 10:57 To: user-zh <[email protected]> Subject: flink消费kafka提交偏移量 各位大佬，我自己使用flink1.11时，消费kafka数据源时候，使用group offset，在外 部的kafka tool发现offset没有及时提交，请问下这个在flink中怎么保证呢
