是这个原因，学习了，感谢！
在 2023-06-15 16:25:30，"yuanfeng hu" <heigebupa...@gmail.com> 写道： >消费者要设置事务隔离级别 > >> 2023年6月15日 16:23，163 <xg302801...@163.com> 写道： >> >> 据我了解，kafka支持事务，开启checkpoint及exactly-once后仅当checkpoint执行完毕后才能将数据写入kafka中。测试：flink读取kafka的topic >> a写入topic b，开启checkpoint及exactly-once，flink未执行完新一次的checkpoint，但topic >> b已经可以消费到新数据，这是什么原因？请大家指教！ >
