io.smallrye.reactive.messaging.kafka

Class OutgoingKafkaRecordMetadata<K>

java.lang.Object

io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecordMetadata<K>

All Implemented Interfaces:

KafkaMessageMetadata<K>

public class OutgoingKafkaRecordMetadata<K>
extends Object
implements KafkaMessageMetadata<K>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>

Constructor Summary

Constructors

Constructor and Description
OutgoingKafkaRecordMetadata(String topic, K key, int partition, Instant timestamp, org.apache.kafka.common.header.Headers headers)

Method Summary

Modifier and Type	Method and Description
static <K> OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>	builder()
org.apache.kafka.common.header.Headers	getHeaders()
K	getKey()
int	getPartition()
Instant	getTimestamp()
String	getTopic()

Methods inherited from class java.lang.Object

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

Constructor Detail

OutgoingKafkaRecordMetadata

public OutgoingKafkaRecordMetadata(String topic,
                                   K key,
                                   int partition,
                                   Instant timestamp,
                                   org.apache.kafka.common.header.Headers headers)

Method Detail

builder

public static <K> OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K> builder()

getPartition

public int getPartition()

Specified by:

getPartition in interface KafkaMessageMetadata<K>

getTimestamp

public Instant getTimestamp()

Specified by:

getTimestamp in interface KafkaMessageMetadata<K>

getHeaders

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

Specified by:

getHeaders in interface KafkaMessageMetadata<K>

getTopic

public String getTopic()

Specified by:

getTopic in interface KafkaMessageMetadata<K>

getKey

public K getKey()

Specified by:

getKey in interface KafkaMessageMetadata<K>