[jira] [Updated] (KAFKA-6457) Error: NOT_LEADER_FOR_PARTITION leads to NPE
[ https://issues.apache.org/jira/browse/KAFKA-6457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6457: --- Component/s: (was: streams) consumer > 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: consumer >Affects Versions: 1.0.0 >Reporter: Seweryn Habdank-Wojewodzki >Priority: Major > Fix For: 1.0.1 > > > 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)
[jira] [Updated] (KAFKA-6457) Error: NOT_LEADER_FOR_PARTITION leads to NPE
[ https://issues.apache.org/jira/browse/KAFKA-6457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe updated KAFKA-6457: --- Fix Version/s: 1.0.1 > 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 > Fix For: 1.0.1 > > > 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)