Interface RecordContext
-
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 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
-
-