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 Summary
Constructors Constructor Description CapturedForward(Record<K,V> record)
CapturedForward(Record<K,V> record, Optional<String> childName)
-
-
-
Method Detail
-
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.
-
-