...

org/apache/kafka/streams/Topology will be extended with an addReadOnlyStateStore method allowing the changelog topic to be passed in.

Proposed Changes

Extend the topology API with

...

the following method:

addReadOnlyStateStore(final StoreBuilder<?> storeBuilder,
                      final String topic,
                      final TimestampExtractor timestampExtractor,
                      final Deserializer<KIn> keyDeserializer,
                      final Deserializer<VIn> valueDeserializer,
                      final ProcessorSupplier<KIn, VIn, Void, Void> stateUpdateSupplier)

This method

Implementation Plan

The addReadOnlyStateStore()  method would be a wrapper around the following calls:

• Create a source for the topic and KV deserializers being passed in.
• Create a processor based on the ProcessorProviderProcessorSupplier.
• Create a state store based on the passed store builder.

...