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