conduktor.io ↗

KIP-401 — TransformerSupplier/ProcessorSupplier StateStore connecting

Accepted Kafka 2.6 Streams

Allows `ProcessorSupplier` and `TransformerSupplier` implementations to declare their associated state stores via a `stores()` method so callers do not need to separately pass store names when building topologies with `KStream.process()`. The requirement to pass state store names externally alongside the supplier was boilerplate that forced topology builders to know implementation details of the processor.

Details

AuthorPaul Whalen
StatusAccepted
Kafka Version2.6
JIRAKAFKA-7523
WikiView on Apache Wiki
Created2018-12-09
Last Modified2020-04-30
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.