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)
