Package org.apache.kafka.streams.processor

Class MockProcessorContext.CapturedForward

java.lang.Object

org.apache.kafka.streams.processor.MockProcessorContext.CapturedForward

Enclosing class:

MockProcessorContext

public static class MockProcessorContext.CapturedForward
extends java.lang.Object

Method Summary

Modifier and Type	Method	Description
java.lang.String	childName()	The child this data was forwarded to.
KeyValue	keyValue()	The data forwarded.
long	timestamp()	The timestamp attached to the forwarded record.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

childName

public java.lang.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.