goutamadwant commented on issue #4199: URL: https://github.com/apache/iggy/issues/4199#issuecomment-5693052193
@mmodzelewski @kparisa could you take a look at the checkpoint/replay approach mentioned here ? I reproduced the skipped records with a real Flink restart and a matching Iggy server. I’d like to confirm how Flink checkpoint offsets should interact with consumer-group offsets before implementing the fix. Let me know. thanks! -- 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]
