Axual Streams fails with IllegalStateException finding partitions
Summary
When starting the Axual Streams application, it fails with an IllegalStateException.
Steps to reproduce
- Start the Axual Streams app
- Start a separate producer and produce messages to be processed by the Axual Streams app
- Stop the Axual Streams app (it needs to have committed offsets for the previous step)
- Start the Axual Streams app again. It will fail now, trying to restore its state using the offsets stored in Kafka
Example Project
I do not have one.
What is the current bug behavior?
It fails with the exception, see partial logs down here.
What is the expected correct behavior?
It starts.
Relevant logs and/or screenshots
ERROR AxualStreams:95 - Uncaught exception in AxualStreams thread (streams-xxx-1-StreamThread-1)java.lang.IllegalStateException: Partition examplestream-0 not found.at org.apache.kafka.streams.processor.internals.PartitionGroup.setPartitionTime(PartitionGroup.java:124)at org.apache.kafka.streams.processor.internals.StreamTask.initializeTaskTime(StreamTask.java:815)at org.apache.kafka.streams.processor.internals.StreamTask.initializeMetadata(StreamTask.java:795)at org.apache.kafka.streams.processor.internals.StreamTask.completeRestoration(StreamTask.java:229)at org.apache.kafka.streams.processor.internals.TaskManager.tryToCompleteRestoration(TaskManager.java:447)at org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:660)at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:551)at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:510)
Possible fixes
I do not have any.
Edited by Daniel Mulder