gensericghiro opened a new pull request, #20491: URL: https://github.com/apache/kafka/pull/20491
If there's a failure in the kafka consumer constructor, we attempt to close it https://github.com/lianetm/kafka/blob/2329def2ff9ca4f7b9426af159b6fa19a839dc4d/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java#L540 In that case, it could be the case that some components may have not been created, so we should consider some null checks to avoid noisy logs about NPE. This noisy logs have been reported with the console share consumer in a similar scenario, so this task is to review and do a similar fix for the Async if needed. The fix is to check if handlers/invokers are null before trying to close them. Similar to what was done here https://github.com/apache/kafka/pull/20290 -- 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]
