hachikuji commented on PR #16686: URL: https://github.com/apache/kafka/pull/16686#issuecomment-2414611749
@dajac Thanks for the clarification. > When the Consumer is executed in a Thread (e.g. an executor), when the thread is interrupted, poll() throws the InterruptException exception and we interrupt the thread again to preserve the flag if not mistaken. This is due to the call to `currentThread.interrupt()` inside the constructor of `InterruptException`? It seems like a problematic usage. I could imagine that the user might call `commitSync` before closing and that would cause the interrupt to rethrow as well even with the old implementation? Is that right? -- 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
