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