[jira] [Commented] (KAFKA-7565) NPE in KafkaConsumer

["Rajini Sivaram (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/KAFKA-7565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16681595#comment-16681595 ] 

Rajini Sivaram commented on KAFKA-7565:
---------------------------------------

[~avakhrenev] Can you try with the fix from https://issues.apache.org/jira/browse/KAFKA-7280? If you are able to use 2.0.1 RC0, it contains the fix. It will be good to know if you are running into the synchronization issue fixed in that JIRA or if this is a different issue. Thanks.

> NPE in KafkaConsumer
> --------------------
>
>                 Key: KAFKA-7565
>                 URL: https://issues.apache.org/jira/browse/KAFKA-7565
>             Project: Kafka
>          Issue Type: Bug
>          Components: clients
>    Affects Versions: 1.1.1
>            Reporter: Alexey Vakhrenev
>            Priority: Critical
>             Fix For: 2.2.0
>
>
> The stacktrace is
> {noformat}
> 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)
> {noformat}
> 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.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)