Package org.apache.kafka.streams.kstream

Class ForeachProcessor<K,V>

java.lang.Object

org.apache.kafka.streams.kstream.ForeachProcessor<K,V>

All Implemented Interfaces:

Processor<K,V,Void,Void>

public class ForeachProcessor<K,V>
extends Object
implements Processor<K,V,Void,Void>

Constructor Summary

Constructors

Constructor	Description
ForeachProcessor(ForeachAction<K,V> action)

Method Summary

Modifier and Type	Method	Description
void	process(Record<K,V> record)	Process the record.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.kafka.streams.processor.api.Processor

close, init

Constructor Details

ForeachProcessor

public ForeachProcessor(ForeachAction<K,V> action)

Method Details

process

public void process(Record<K,V> record)

Description copied from interface: Processor

Process the record. Note that record metadata is undefined in cases such as a forward call from a punctuator.

Specified by:

process in interface Processor<K,V,Void,Void>

Parameters:

record - the record to process