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