org.apache.kafka.streams.kstream

Interface ForeachAction<K,V>

Type Parameters:

K - original key type

V - original value type

public interface ForeachAction<K,V>

The ForeachAction interface for performing an action on a key-value pair. Note that this action is stateless. If stateful processing is required, consider using KStream.transform(TransformerSupplier, String...) or KStream.process(ProcessorSupplier, String...) instead.

Method Summary

Methods

Modifier and Type	Method and Description
void	apply(K key, V value) Perform an action for each record of a stream.

Method Detail

apply

void apply(K key,
         V value)

Perform an action for each record of a stream.

Parameters:

key - the key of the record

value - the value of the record