public interface RecordContext
Processor
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.header.Headers |
headers() |
long |
offset() |
int |
partition() |
long |
timestamp() |
String |
topic() |
long offset()
long timestamp()
String topic()
int partition()
org.apache.kafka.common.header.Headers headers()