Class MockProcessorContext.CapturedForward
- java.lang.Object
-
- org.apache.kafka.streams.processor.MockProcessorContext.CapturedForward
-
- Enclosing class:
- MockProcessorContext
public static class MockProcessorContext.CapturedForward extends Object
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description StringchildName()The child this data was forwarded to.KeyValuekeyValue()The data forwarded.longtimestamp()The timestamp attached to the forwarded record.StringtoString()
-
-
-
Method Detail
-
childName
public String childName()
The child this data was forwarded to.- Returns:
- The child name, or
nullif it was broadcast.
-
timestamp
public long timestamp()
The timestamp attached to the forwarded record.- Returns:
- A timestamp, or
-1if none was forwarded.
-
keyValue
public KeyValue keyValue()
The data forwarded.- Returns:
- A key/value pair. Not null.
-
-