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

  • 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