lianetm commented on PR #16343: URL: https://github.com/apache/kafka/pull/16343#issuecomment-2173470048
Hey @lucasbru , solved. Issue was that all those integration tests do close with zero timeout, and in that scenario the legacy logic does not propagate a timeout exception while leaving the group (and I was propagating it here). The legacy logic just triggers the leave and waits if it has time. If it doesn't, it just logs a warn [here](https://github.com/apache/kafka/blob/09b4ef416aa54a4e65b297f7e6b47a04e88556f5/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java#L1130-L1141)). So I just did the same on the new consumer. Tried several of the integration test files that were failing and they pass locally now. I'm running them all now while the build here completes. 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]
