dajac commented on PR #16686: URL: https://github.com/apache/kafka/pull/16686#issuecomment-2421838866
@kirktrue Thanks for the summary. I am not sure about 6). In the old implementation, we send it out even if interrupted. I think that we should also clarify how we handle interruption because this is actually the major difference between the old and the new implementation. In the old, we send the request before checking the interrupt flag whereas we implicitly check it before in the new implementation. This is actually why we saw members leaving properly in our tests with the old consumer even though close is still interrupted. I suppose that it is a gray area but let’s try to have a clear statement on it. @chia7712 @hachikuji What’s your take on this? -- 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
