[ 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)