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 Object

Method Summary

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

Methods inherited from class java.lang.Object

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

Method Details

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.

toString

public String toString()

Overrides:

toString in class Object

headers

public Headers headers()