[jira] [Resolved] (KAFKA-12514) NPE in SubscriptionState

["Guozhang Wang (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-12514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Guozhang Wang resolved KAFKA-12514.
-----------------------------------
    Fix Version/s: 3.0.0
       Resolution: Fixed

> NPE in SubscriptionState
> ------------------------
>
>                 Key: KAFKA-12514
>                 URL: https://issues.apache.org/jira/browse/KAFKA-12514
>             Project: Kafka
>          Issue Type: Bug
>          Components: streams
>    Affects Versions: 3.0.0
>            Reporter: John Roesler
>            Assignee: John Roesler
>            Priority: Blocker
>             Fix For: 3.0.0
>
>
> In a soak test, we got this exception:
>  
> {code:java}
> java.lang.NullPointerException	at org.apache.kafka.clients.consumer.internals.SubscriptionState.partitionLag(SubscriptionState.java:545)	at org.apache.kafka.clients.consumer.KafkaConsumer.currentLag(KafkaConsumer.java:2241)	at org.apache.kafka.streams.processor.internals.PartitionGroup.readyToProcess(PartitionGroup.java:143)	at org.apache.kafka.streams.processor.internals.StreamTask.isProcessable(StreamTask.java:650)	at org.apache.kafka.streams.processor.internals.StreamTask.process(StreamTask.java:661)	at org.apache.kafka.streams.processor.internals.TaskManager.process(TaskManager.java:1114) {code}
> This is related to the implementation of:
> [https://cwiki.apache.org/confluence/display/KAFKA/KIP-695%3A+Further+Improve+Kafka+Streams+Timestamp+Synchronization]
> aka
> https://issues.apache.org/jira/browse/KAFKA-10091
>  
> Luckily, the stack trace is pretty unambiguous. I'll open a PR shortly.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)