io.smallrye.reactive.messaging.kafka.api

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

Modifier and Type	Method and Description
org.apache.kafka.common.header.Headers	getHeaders() Get the Kafka headers
K	getKey() Get the key
int	getPartition() Get the partition
Instant	getTimestamp() Get the timestamp
String	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