Package io.smallrye.reactive.messaging.kafka

Class OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>

java.lang.Object

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

Enclosing class:

OutgoingKafkaRecordMetadata<K>

public static final class OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>
extends Object

Constructor Summary

Constructors

Constructor	Description
OutgoingKafkaRecordMetadataBuilder()

Method Summary

Modifier and Type	Method	Description
OutgoingKafkaRecordMetadata<K>	build()
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>	withHeaders(List<org.apache.kafka.common.header.internals.RecordHeader> headers)
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>	withHeaders(org.apache.kafka.common.header.Headers headers)
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>	withKey(K recordKey)
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>	withPartition(int partition)
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>	withTimestamp(Instant timestamp)
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>	withTopic(String topic)

Methods inherited from class java.lang.Object

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

Constructor Detail

OutgoingKafkaRecordMetadataBuilder

public OutgoingKafkaRecordMetadataBuilder()

Method Detail

withTopic

public OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K> withTopic(String topic)

withKey

public OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K> withKey(K recordKey)

withPartition

public OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K> withPartition(int partition)

withTimestamp

public OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K> withTimestamp(Instant timestamp)

withHeaders

public OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K> withHeaders(org.apache.kafka.common.header.Headers headers)

build

public OutgoingKafkaRecordMetadata<K> build()

withHeaders

public OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K> withHeaders(List<org.apache.kafka.common.header.internals.RecordHeader> headers)