org.apache.kafka.streams.processor

Interface RecordContext

public interface RecordContext

The context associated with the current record being processed by an Processor

Method Summary

Modifier and Type	Method and Description
Headers	headers()
long	offset()
int	partition()
long	timestamp()
String	topic()

Method Detail

offset

long offset()

Returns:

The offset of the original record received from Kafka; could be -1 if it is not available

timestamp

long timestamp()

Returns:

The timestamp extracted from the record received from Kafka; could be -1 if it is not available

topic

String topic()

Returns:

The topic the record was received on; could be null if it is not available

partition

int partition()

Returns:

The partition the record was received on; could be -1 if it is not available

headers

Headers headers()

Returns:

The headers from the record received from Kafka; could be null if it is not available