Class MockProcessorContext.CapturedForward
java.lang.Object
org.apache.kafka.streams.processor.MockProcessorContext.CapturedForward
- Enclosing class:
- MockProcessorContext
-
Method Summary
-
Method Details
-
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
The data forwarded.- Returns:
- A key/value pair. Not null.
-
toString
-
headers
-