io.smallrye.reactive.messaging.kafka

Interface KafkaMessageMetadata<K>

All Known Implementing Classes:

IncomingKafkaRecordMetadata, OutgoingKafkaRecordMetadata

public interface KafkaMessageMetadata<K>

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.common.header.Headers	getHeaders()
K	getKey()
int	getPartition()
Instant	getTimestamp()
String	getTopic()

Method Detail

getTopic

String getTopic()

getKey

K getKey()

getTimestamp

Instant getTimestamp()

getHeaders

org.apache.kafka.common.header.Headers getHeaders()

getPartition

int getPartition()