public class KTableSource<K,V> extends java.lang.Object implements ProcessorSupplier<K,V>
Modifier and Type | Field and Description |
---|---|
java.lang.String |
storeName |
Constructor and Description |
---|
KTableSource(java.lang.String storeName) |
Modifier and Type | Method and Description |
---|---|
void |
enableSendingOldValues() |
Processor<K,V> |
get()
Return a new
Processor instance. |
public Processor<K,V> get()
ProcessorSupplier
Processor
instance.get
in interface ProcessorSupplier<K,V>
Processor
instancepublic void enableSendingOldValues()