hubcio commented on issue #3635: URL: https://github.com/apache/iggy/issues/3635#issuecomment-5171684747
AFAIK no one is working on it now. before providing fix, please reproduce the scenario. easiest way: run postgres_source, kill the server mid-polling, check that the tracking offset moves past rows that never landed in iggy. @rohankumardubey have you already joined our discord? one hint: runtime already skips state save on send failure (#3321), and producer.send() in direct mode returns a real ack. the actual gap is that the send result never crosses the ffi back to the plugin, which advances its in-memory offset in poll() regardless. so your scope is right, but design doc first please (can be under this issue), new ack entry point changes the ffi surface in sdk/src/source.rs and that breaks pre-built plugins. i think its impossible without new ffi api. -- 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]
