Re: flink写kafka 事务问题

[yuanfeng hu]

消费者要设置事务隔离级别

> 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已经可以消费到新数据，这是什么原因？请大家指教！