[
https://issues.apache.org/jira/browse/KAFKA-19572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shivsundar R updated KAFKA-19572:
---------------------------------
Description:
If there is any failure in construction of KafkaShareConsumer, then it logs a
few NPEs while closing.
{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 in the constructor.
We need to ensure we check if the resources are null before closing them.
was:
If there is any failure in construction of KafkaShareConsumer, then it logs an
NPE while closing.
{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 in the constructor.
We need to ensure we check if the resources are null before closing them.
> 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
> Assignee: Shivsundar R
> Priority: Major
>
> If there is any failure in construction of KafkaShareConsumer, then it logs a
> few NPEs while closing.
> {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 in the constructor.
> 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)
