io.smallrye.reactive.messaging.kafka

Class IncomingKafkaRecordMetadata<K,T>

java.lang.Object

io.smallrye.reactive.messaging.kafka.IncomingKafkaRecordMetadata<K,T>

All Implemented Interfaces:

KafkaMessageMetadata<K>

public class IncomingKafkaRecordMetadata<K,T>
extends Object
implements KafkaMessageMetadata<K>

Constructor Summary

Constructors

Constructor and Description
IncomingKafkaRecordMetadata(org.apache.kafka.clients.consumer.ConsumerRecord<K,T> record)

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.common.header.Headers	getHeaders()
K	getKey()
long	getOffset()
int	getPartition()
org.apache.kafka.clients.consumer.ConsumerRecord<K,T>	getRecord()
Instant	getTimestamp()
org.apache.kafka.common.record.TimestampType	getTimestampType()
String	getTopic()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IncomingKafkaRecordMetadata

public IncomingKafkaRecordMetadata(org.apache.kafka.clients.consumer.ConsumerRecord<K,T> record)

Method Detail

getTopic

public String getTopic()

Specified by:

getTopic in interface KafkaMessageMetadata<K>

getKey

public K getKey()

Specified by:

getKey in interface KafkaMessageMetadata<K>

getPartition

public int getPartition()

Specified by:

getPartition in interface KafkaMessageMetadata<K>

getTimestamp

public Instant getTimestamp()

Specified by:

getTimestamp in interface KafkaMessageMetadata<K>

getTimestampType

public org.apache.kafka.common.record.TimestampType getTimestampType()

getOffset

public long getOffset()

getHeaders

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

Specified by:

getHeaders in interface KafkaMessageMetadata<K>

getRecord

public org.apache.kafka.clients.consumer.ConsumerRecord<K,T> getRecord()