Interface RecordContext
-
public interface RecordContextThe context associated with the current record being processed by anProcessor
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Headersheaders()longoffset()intpartition()longtimestamp()Stringtopic()
-
-
-
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
-
-