Axual Streams fails with IllegalStateException finding partitions

Summary

When starting the Axual Streams application, it fails with an IllegalStateException.

Steps to reproduce

  1. Start the Axual Streams app
  2. Start a separate producer and produce messages to be processed by the Axual Streams app
  3. Stop the Axual Streams app (it needs to have committed offsets for the previous step)
  4. 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