Package org.apache.kafka.streams.kstream
Interface ForeachAction<K,V>
-
- Type Parameters:
K- key typeV- value type
public interface ForeachAction<K,V>TheForeachActioninterface 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 voidapply(K key, V value)Perform an action for each record of a stream.
-