[
https://issues.apache.org/jira/browse/KAFKA-6457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16337422#comment-16337422
]
Seweryn Habdank-Wojewodzki commented on KAFKA-6457:
---------------------------------------------------
All those tickets: KAFKA-6459, KAFKA-6457, KAFKA-5882 might be connected as
more less something is wrong when rebalancing (or new leader is voted) happens
in AbstractCoordinator. There are some places in code where objects are used,
but they are {{null}}. And this class is common for all my stack traces. It is
ofcourse question if AbstractCoordinator wrongly handles {{null}} or null shall
never appead in those places, but the underlying class, which provides objects,
deletes/resets to null them and shall not provided those objects.
> Error: NOT_LEADER_FOR_PARTITION leads to NPE
> --------------------------------------------
>
> Key: KAFKA-6457
> URL: https://issues.apache.org/jira/browse/KAFKA-6457
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 1.0.0
> Reporter: Seweryn Habdank-Wojewodzki
> Priority: Major
>
> One of our nodes was dead. Then the second one tooks all responsibility.
> But streamming aplication in the meanwhile crashed due to NPE caused by
> {{Error: NOT_LEADER_FOR_PARTITION}}.
> The stack trace is below.
>
> Is it something expected?
>
> {code:java}
> 2018-01-17 11:47:21 [my] [WARN ] Sender:251 - [Producer ...2018-01-17
> 11:47:21 [my] [WARN ] Sender:251 - [Producer
> clientId=restreamer-my-fef07ca9-b067-45c0-a5af-68b5a1730dac-StreamThread-1-producer]
> Got error produce response with correlation id 768962 on topic-partition
> my_internal_topic-5, retrying (9 attempts left). Error:
> NOT_LEADER_FOR_PARTITION
> 2018-01-17 11:47:21 [my] [WARN ] Sender:251 - [Producer
> clientId=restreamer-my-fef07ca9-b067-45c0-a5af-68b5a1730dac-StreamThread-1-producer]
> Got error produce response with correlation id 768962 on topic-partition
> my_internal_topic-7, retrying (9 attempts left). Error:
> NOT_LEADER_FOR_PARTITION
> 2018-01-17 11:47:21 [my] [ERROR] AbstractCoordinator:296 - [Consumer
> clientId=restreamer-my-fef07ca9-b067-45c0-a5af-68b5a1730dac-StreamThread-1-consumer,
> groupId=restreamer-my] Heartbeat thread for group restreamer-my failed due
> to unexpected error
> java.lang.NullPointerException: null
> at
> org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:436)
> ~[my-restreamer.jar:?]
> at org.apache.kafka.common.network.Selector.poll(Selector.java:395)
> ~[my-restreamer.jar:?]
> at
> org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:460)
> ~[my-restreamer.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:238)
> ~[my-restreamer.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.pollNoWakeup(ConsumerNetworkClient.java:275)
> ~[my-restreamer.jar:?]
> at
> org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:934)
> [my-restreamer.jar:?]
> {code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
