是这个原因,学习了,感谢!
在 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已经可以消费到新数据,这是什么原因?请大家指教!