Shivsundar R created KAFKA-19572:
------------------------------------
Summary: Fix NPE messages in ConsoleShareConsumer.
Key: KAFKA-19572
URL: https://issues.apache.org/jira/browse/KAFKA-19572
Project: Kafka
Issue Type: Sub-task
Reporter: Shivsundar R
If we gave an invalid bootstrap-server URL in the kafka-console-share-consumer
command, then it throws NPE.
{code:java}
[2025-07-31 21:45:46,484] ERROR [ShareConsumer clientId=console-share-consumer,
groupId=test_1] Failed to release assignment before closing consumer
(org.apache.kafka.clients.consumer.internals.ShareConsumerImpl)
java.lang.NullPointerException: Cannot invoke
"org.apache.kafka.clients.consumer.internals.events.ApplicationEventHandler.add(org.apache.kafka.clients.consumer.internals.events.ApplicationEvent)"
because "this.applicationEventHandler" is null at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.sendAcknowledgementsAndLeaveGroup(ShareConsumerImpl.java:936)
~[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.lambda$close$4(ShareConsumerImpl.java:882)
~[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.common.utils.Utils.swallow(Utils.java:1042)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.close(ShareConsumerImpl.java:881)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.<init>(ShareConsumerImpl.java:335)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.<init>(ShareConsumerImpl.java:209)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.internals.ShareConsumerDelegateCreator.create(ShareConsumerDelegateCreator.java:49)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.KafkaShareConsumer.<init>(KafkaShareConsumer.java:383)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.KafkaShareConsumer.<init>(KafkaShareConsumer.java:376)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.KafkaShareConsumer.<init>(KafkaShareConsumer.java:357)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.tools.consumer.ConsoleShareConsumer.run(ConsoleShareConsumer.java:75)
[kafka-tools-4.1.0.jar:?] at
org.apache.kafka.tools.consumer.ConsoleShareConsumer.main(ConsoleShareConsumer.java:57)
[kafka-tools-4.1.0.jar:?] [2025-07-31 21:45:46,487] ERROR [ShareConsumer
clientId=console-share-consumer, groupId=test_1] Failed to stop finding
coordinator (org.apache.kafka.clients.consumer.internals.ShareConsumerImpl)
java.lang.NullPointerException: Cannot invoke
"org.apache.kafka.clients.consumer.internals.events.ApplicationEventHandler.add(org.apache.kafka.clients.consumer.internals.events.ApplicationEvent)"
because "this.applicationEventHandler" is null at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.stopFindCoordinatorOnClose(ShareConsumerImpl.java:915)
~[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.common.utils.Utils.swallow(Utils.java:1042)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.close(ShareConsumerImpl.java:883)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.<init>(ShareConsumerImpl.java:335)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.<init>(ShareConsumerImpl.java:209)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.internals.ShareConsumerDelegateCreator.create(ShareConsumerDelegateCreator.java:49)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.KafkaShareConsumer.<init>(KafkaShareConsumer.java:383)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.KafkaShareConsumer.<init>(KafkaShareConsumer.java:376)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.KafkaShareConsumer.<init>(KafkaShareConsumer.java:357)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.tools.consumer.ConsoleShareConsumer.run(ConsoleShareConsumer.java:75)
[kafka-tools-4.1.0.jar:?] at
org.apache.kafka.tools.consumer.ConsoleShareConsumer.main(ConsoleShareConsumer.java:57)
[kafka-tools-4.1.0.jar:?] [2025-07-31 21:45:46,488] ERROR [ShareConsumer
clientId=console-share-consumer, groupId=test_1] Failed invoking
acknowledgement commit callback
(org.apache.kafka.clients.consumer.internals.ShareConsumerImpl)
java.lang.NullPointerException: Cannot invoke
"org.apache.kafka.clients.consumer.internals.events.CompletableEventReaper.reap(long)"
because "this.backgroundEventReaper" is null at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.processBackgroundEvents(ShareConsumerImpl.java:1107)
~[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.processBackgroundEvents(ShareConsumerImpl.java:1074)
~[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.handleCompletedAcknowledgements(ShareConsumerImpl.java:1023)
~[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.lambda$close$5(ShareConsumerImpl.java:886)
~[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.common.utils.Utils.swallow(Utils.java:1042)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.close(ShareConsumerImpl.java:885)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.<init>(ShareConsumerImpl.java:335)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.<init>(ShareConsumerImpl.java:209)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.internals.ShareConsumerDelegateCreator.create(ShareConsumerDelegateCreator.java:49)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.KafkaShareConsumer.<init>(KafkaShareConsumer.java:383)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.KafkaShareConsumer.<init>(KafkaShareConsumer.java:376)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.KafkaShareConsumer.<init>(KafkaShareConsumer.java:357)
[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.tools.consumer.ConsoleShareConsumer.run(ConsoleShareConsumer.java:75)
[kafka-tools-4.1.0.jar:?] at
org.apache.kafka.tools.consumer.ConsoleShareConsumer.main(ConsoleShareConsumer.java:57)
[kafka-tools-4.1.0.jar:?] [2025-07-31 21:45:46,490] ERROR Unknown error when
running consumer: (org.apache.kafka.tools.consumer.ConsoleShareConsumer)
org.apache.kafka.common.KafkaException: Failed to construct Kafka share
consumer at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.<init>(ShareConsumerImpl.java:338)
~[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.internals.ShareConsumerImpl.<init>(ShareConsumerImpl.java:209)
~[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.internals.ShareConsumerDelegateCreator.create(ShareConsumerDelegateCreator.java:49)
~[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.KafkaShareConsumer.<init>(KafkaShareConsumer.java:383)
~[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.KafkaShareConsumer.<init>(KafkaShareConsumer.java:376)
~[kafka-clients-4.1.0.jar:?] at
org.apache.kafka.clients.consumer.KafkaShareConsumer.<init>(KafkaShareConsumer.java:357)
~[kafka-clients-4.1.0.jar:?]{code}
This is because we are trying to close some resources which were not
initialized due to invalid bootstrap-servers in the input.
We need to ensure we check if the resources are null before closing them.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
