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.Headers
getHeaders()
Get the Kafka headersK
getKey()
Get the keyint
getPartition()
Get the partitionInstant
getTimestamp()
Get the timestampString
getTopic()
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
-
-