K- the type of keys
V- the type of values
public interface ProcessorSupplier<K,V> extends ConnectedStoreProvider, Supplier<Processor<K,V>>
It is used in
Topology for adding new processor operators, whose generated
topology can then be replicated (and thus creating one or more
and distributed to multiple stream threads.
The supplier should always generate a new instance each time
get() gets called. Creating
Processor object and returning the same object reference in
get() would be
a violation of the supplier pattern and leads to runtime exceptions.
Processorinstance. The supplier should always generate a new instance each time