Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Won't Fix
-
1.14.4
-
None
-
None
-
Important
Description
as we can see, the new KafkaSink aborts all transactions that have been created by a subtask in a previous run, only return when get a producerId was unused before(epoch=0). But this can take a long time, especially if the task has been started and cancelled many times before. In my tests, it even took 10 minutes. Is there a better way to solve this problem, or do what FlinkKafkaProducer did.