John Calcote created KAFKA-13686: ------------------------------------ Summary: NullPointerException in Selector.pollSelectionKeys Key: KAFKA-13686 URL: https://issues.apache.org/jira/browse/KAFKA-13686 Project: Kafka Issue Type: Bug Components: clients Affects Versions: 0.11.0.1 Environment: Linux/Centos 7.6, Java JVM - 1.8.0_181 Reporter: John Calcote
Seeing repeated NPEs in Selector.pollSelectionKeys: {noformat} java.lang.NullPointerException: null at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:353) ~[kafka-clients-0.11.0.1.jar:?] at org.apache.kafka.common.network.Selector.poll(Selector.java:326) ~[kafka-clients-0.11.0.1.jar:?] at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:433) ~[kafka-clients-0.11.0.1.jar:?] at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:232) ~[kafka-clients-0.11.0.1.jar:?] at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:208) ~[kafka-clients-0.11.0.1.jar:?] at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:184) ~[kafka-clients-0.11.0.1.jar:?] at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:217) ~[kafka-clients-0.11.0.1.jar:?] at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:203) ~[kafka-clients-0.11.0.1.jar:?] at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:286) ~[kafka-clients-0.11.0.1.jar:?] at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1078) ~[kafka-clients-0.11.0.1.jar:?] at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1043) ~[kafka-clients-0.11.0.1.jar:?] {noformat} {noformat} void pollSelectionKeys(Iterable<SelectionKey> selectionKeys, boolean isImmediatelyConnected, long currentTimeNanos) { Iterator<SelectionKey> iterator = selectionKeys.iterator(); while (iterator.hasNext()) { SelectionKey key = iterator.next(); iterator.remove(); KafkaChannel channel = channel(key); long channelStartTimeNanos = recordTimePerConnection ? time.nanoseconds() : 0; // register all per-connection metrics at once sensors.maybeRegisterConnectionMetrics(channel.id()); <---- NPE HERE if (idleExpiryManager != null) idleExpiryManager.update(channel.id(), currentTimeNanos); try { ... {noformat} The only two possibilities are: # sensors is null # channel is null sensors is not likely in my mind - it's more likely that the attachment on the key is null, but I don't have enough background in kafka client code to determine why this might be. -- This message was sent by Atlassian Jira (v8.20.1#820001)