[KAFKA-12514] NPE in SubscriptionState - ASF JIRA

Attach files

Attach Screenshot

Voters

Watch issue

Watchers

Create sub-task

Link

Clone

Update Comment Author

Replace String in Comment

Update Comment Visibility

Delete Comments

XML

Word

Printable

JSON

Details

Type: Bug
Status: Resolved
Priority: Blocker
Resolution: Fixed
Affects Version/s: 3.0.0
Fix Version/s: 3.0.0
Component/s: streams
Labels:
None

Description

In a soak test, we got this exception:

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)

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.