Package org.apache.kafka.streams.processor.api

Class MockProcessorContext.CapturedForward<K,V>

java.lang.Object
org.apache.kafka.streams.processor.api.MockProcessorContext.CapturedForward<K,V>
Enclosing class:
MockProcessorContext<KForward,VForward>
public static final class MockProcessorContext.CapturedForward<K,V> extends Object

  • Constructor Details

    • CapturedForward

      public CapturedForward(Record<K,V> record)

    • CapturedForward

      public CapturedForward(Record<K,V> record, Optional<String> childName)

  • Method Details

    • childName

      public Optional<String> childName()
      The child this data was forwarded to.
      Returns:
      If present, the child name the record was forwarded to. If empty, the forward was a broadcast.

    • record

      public Record<K,V> record()
      The record that was forwarded.
      Returns:
      The forwarded record. Not null.

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object