K - key typeV - value typepublic interface ForeachAction<K,V>ForeachAction interface for performing an action on a key-value pair. This is a stateless record-by-record operation, i.e, apply(Object, Object) is invoked individually for each record of a stream. If stateful processing is required, consider using KStream#process(...).KStream.foreach(ForeachAction)| Modifier and Type | Method and Description |
|---|---|
void | apply(K key, V value)Perform an action for each record of a stream. |