ShivsundarR commented on PR #19417: URL: https://github.com/apache/kafka/pull/19417#issuecomment-2804951158
@AndrewJSchofield Thanks for the review, I have addressed all the comments and updated the PR. - For the exception thrown on unacknowledged records, I did some experiments with a mock application and it seems to be working fine with the current code. The user can close the consumer or attempt to acknowledge the remaining records. - Once all the unacknowledged records are acknowledged, the `IllegalStateException` exception wont be thrown and regular consumption will resume. I have updated a unit test reflecting the above scenario as well. -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
