Interface RecordContext
-
- All Known Implementing Classes:
ProcessorRecordContext
public interface RecordContext
The context associated with the current record being processed by anProcessor
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description org.apache.kafka.common.header.Headers
headers()
long
offset()
int
partition()
long
timestamp()
java.lang.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
java.lang.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
org.apache.kafka.common.header.Headers headers()
- Returns:
- The headers from the record received from Kafka; could be null if it is not available
-
-