Package org.apache.kafka.streams.kstream
Interface ForeachAction<K,V>
-
- Type Parameters:
K
- key typeV
- value type
public interface ForeachAction<K,V>
TheForeachAction
interface for performing an action on akey-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 usingKStream#process(...)
.- See Also:
KStream.foreach(ForeachAction)
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
apply(K key, V value)
Perform an action for each record of a stream.
-