Hi,
This is the contract of 2PC transactions.
Multiple commit retries should result in only one commit which actually happens
in the external system.
The external system has to support deduplication of committed transactions,
e.g. by some unique id.
Best,
Andrey
> On 10 Oct 2019, at 07:15, 121
After reading about FlinkKafkaProducer011 and 2PC function in FLINK, I know,
when snapshotState(),
preCommit currentTransaction.
add to the State.
when Checkpoint done and notifyCheckpointComplete(),
producer will commit currentTransaction to brokers.
when initializeState(),
restore from State.
c
