You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "John Roesler (Jira)" <ji...@apache.org> on 2021/03/21 02:27:00 UTC
[jira] [Created] (KAFKA-12514) NPE in SubscriptionState
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)