hackereye commented on issue #10574: URL: https://github.com/apache/seatunnel/issues/10574#issuecomment-4027761982
Great analysis, thank you for digging into this! Your conclusion matches my understanding - the Kafka source recovery logic is definitely the culprit here. The way addSplitsBack() rewrites offsets during restore breaks the exactly-once guarantee. The proposed fix direction (preserve checkpointed offsets, separate recovery from bounded split logic) sounds exactly right. Looking forward to the patch. Let me know if you need any help with testing or review. -- 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]
