Class MockProcessorContext.CapturedForward

java.lang.Object
org.apache.kafka.streams.processor.MockProcessorContext.CapturedForward
Enclosing class:
MockProcessorContext

public static class MockProcessorContext.CapturedForward extends Object
  • Method Details

    • childName

      public String childName()
      The child this data was forwarded to.
      Returns:
      The child name, or null if it was broadcast.
    • timestamp

      public long timestamp()
      The timestamp attached to the forwarded record.
      Returns:
      A timestamp, or -1 if none was forwarded.
    • keyValue

      public KeyValue keyValue()
      The data forwarded.
      Returns:
      A key/value pair. Not null.
    • toString

      public String toString()
      Overrides:
      toString in class Object
    • headers

      public Headers headers()