Description
StreamsBuilder#addGlobalStore is conceptually a 1:1 copy of Topology#addGlobalStore, that would follow DSL design principles though. Atm, StreamsBuilder#addGlobalStore does not follow provide a good user experience as it forces users to specify names for processor names – processor name are a Processor API detail should be hidden in the DSL. The current API is the following:
public synchronized StreamsBuilder addGlobalStore(final StoreBuilder storeBuilder, final String topic, final String sourceName, final Consumed consumed, final String processorName, final ProcessorSupplier stateUpdateSupplier)
We should remove the two parameters sourceName and processorName. To be backward compatible, the current method must be deprecated and a new method should be added with reduced number of parameters.
Attachments
Issue Links
- relates to
-
KAFKA-6265 GlobalKTable missing #queryableStoreName()
-
- Resolved
-
- links to
- mentioned in
-
Page Loading...