flink写kafka 事务问题

[163]

据我了解，kafka支持事务，开启checkpoint及exactly-once后仅当checkpoint执行完毕后才能将数据写入kafka中。测试：flink读取kafka的topic
 a写入topic b，开启checkpoint及exactly-once，flink未执行完新一次的checkpoint，但topic 
b已经可以消费到新数据，这是什么原因？请大家指教！