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