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 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