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>
@Deprecatedpublic class ForeachProcessor<K,V>extends Object implements Processor<K,V,Void,Void>
Deprecated.
Since 4.0 and should not be used any longer.

  • Constructor Details

    • ForeachProcessor

      public ForeachProcessor(ForeachAction<K,V> action)
      Deprecated.

  • Method Details

    • process

      public void process(Record<K,V> record)
      Deprecated.
      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