gharris1727 commented on PR #14763: URL: https://github.com/apache/kafka/pull/14763#issuecomment-1850969462
Hi @C0urante I found another very similar problem, where InternalTopicsIntegrationTest was causing us to leak clients. There, the "bad topics" cause startServices to throw an exception, preventing stopServices from being called in halt(). I implemented nearly the same fix, by adding a stopServices call to the DistributedHerder::stop method, similar to what is already happening in the StandaloneHerder. PTAL 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]
