[KAFKA-7565] NPE in KafkaConsumer

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Duplicate
• Affects Version/s: 1.1.1
• Component/s: clients
• Assignee: Unassigned
• Reporter: Alexey Vakhrenev
• Created: 29/Oct/18 17:47
• Updated: 04/Jun/19 23:04
• Resolved: 21/May/19 20:52

Description

The stacktrace is

java.lang.NullPointerException
        at org.apache.kafka.clients.consumer.internals.Fetcher$1.onSuccess(Fetcher.java:221)
        at org.apache.kafka.clients.consumer.internals.Fetcher$1.onSuccess(Fetcher.java:202)
        at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:167)
        at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:127)
        at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:563)
        at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:390)
        at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:244)
        at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:233)
        at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1171)
        at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1115)

Couldn't find minimal reproducer, but it happens quite often in our system. We use pause() and wakeup() methods quite extensively, maybe it is somehow related.

Issue Links

• duplicates: KAFKA-7280 ConcurrentModificationException in FetchSessionHandler in heartbeat thread
• duplicates: KAFKA-8052 Intermittent INVALID_FETCH_SESSION_EPOCH error on FETCH request
• links to: GitHub Pull Request #6427