zephyr45 commented on issue #13044: URL: https://github.com/apache/seatunnel/issues/13044#issuecomment-6471138641
Yes, I am contributing to Apache SeaTunnel and I will work on this. I have traced the shared transaction IDs through KafkaSinkWriter and KafkaTransactionSender. I will isolate each writer's IDs and cover checkpoint rotation and recovery/abort, including restoration of existing state. I will add two-writer regression coverage and a parallel exactly-once Kafka E2E test that verifies every expected record with read_committed. Thanks for the detailed reproduction. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
