rohankumardubey commented on issue #3635: URL: https://github.com/apache/iggy/issues/3635#issuecomment-5172204395
Thanks for the clarification. I understand that the runtime already avoids persisting connector state when `producer.send()` fails, as covered by the current flow around #3321. The remaining concern appears to be that the send result does not cross the FFI boundary back to the source plugin, so its in-memory cursor or destructive state changes may already have advanced. I’ll first reproduce this with `postgres_source` by interrupting the server during polling and compare the plugin’s tracking offset, persisted runtime state, and resulting records after recovery. I’ll share the reproduction results and a design proposal here before making any implementation changes. I’ve also already joined the Apache Iggy Discord. -- 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]
