Interface KafkaMessageMetadata<K>
-
- Type Parameters:
K- the Kafka record key type
- All Known Subinterfaces:
KafkaMessageMetadata<K>
- All Known Implementing Classes:
IncomingKafkaRecordMetadata,IncomingKafkaRecordMetadata,OutgoingKafkaRecordMetadata,OutgoingKafkaRecordMetadata
public interface KafkaMessageMetadata<K>Common interface for
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description org.apache.kafka.common.header.HeadersgetHeaders()Get the Kafka headersKgetKey()Get the keyintgetPartition()Get the partitionInstantgetTimestamp()Get the timestampStringgetTopic()Get the topic
-
-
-
Method Detail
-
getTopic
String getTopic()
Get the topic- Returns:
- the name of the topic
-
getKey
K getKey()
Get the key- Returns:
- the key
-
getTimestamp
Instant getTimestamp()
Get the timestamp- Returns:
- the timestamp
-
getHeaders
org.apache.kafka.common.header.Headers getHeaders()
Get the Kafka headers- Returns:
- the Kafka headers
-
getPartition
int getPartition()
Get the partition- Returns:
- the partition
-
-