[GitHub] [kafka] vvcephei commented on issue #5647: KAFKA-7367: Ensure stateless topologies don't require disk access

[GitHub]

I've currently just implemented the test (which fails). Fix pending...

The culprit is this, in the KafkaStreams constructor:
```java
        try {
            stateDirectory = new StateDirectory(config, time);
        } catch (final ProcessorStateException fatal) {
            throw new StreamsException(fatal);
        }
```

[ Full content available at: https://github.com/apache/kafka/pull/5647 ]
This message was relayed via gitbox.apache.org for devnull@infra.apache.org