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 String
childName()
The child this data was forwarded to.KeyValue
keyValue()
The data forwarded.long
timestamp()
The timestamp attached to the forwarded record.String
toString()
-
-
-
Method Detail
-
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.
-
-