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

["John Roesler (Jira)" <ji...@apache.org>]

John Roesler created KAFKA-12514:
------------------------------------

             Summary: 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


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)