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)