Interface ProcessorSupplier<K,V>
- Type Parameters:
K
- the type of keysV
- the type of values
- All Superinterfaces:
ConnectedStoreProvider
,Supplier<Processor<K,
V>>
@Deprecated
public interface ProcessorSupplier<K,V>
extends ConnectedStoreProvider, Supplier<Processor<K,V>>
Deprecated.
A processor supplier that can create one or more
Processor
instances.
It is used in Topology
for adding new processor operators, whose generated
topology can then be replicated (and thus creating one or more Processor
instances)
and distributed to multiple stream threads.
The supplier should always generate a new instance each time get()
gets called. Creating
a single Processor
object and returning the same object reference in get()
would be
a violation of the supplier pattern and leads to runtime exceptions.
-
Method Summary
Methods inherited from interface org.apache.kafka.streams.processor.ConnectedStoreProvider
stores
-
Method Details
-
get
Deprecated.
-
ProcessorSupplier
instead.