Uses of Class
io.smallrye.reactive.messaging.kafka.api.OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder

Packages that use OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder

Package	Description
io.smallrye.reactive.messaging.kafka.api

Uses of OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder in io.smallrye.reactive.messaging.kafka.api

Methods in io.smallrye.reactive.messaging.kafka.api that return OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder

Modifier and Type	Method	Description
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>	OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder.addHeaders(org.apache.kafka.common.header.internals.RecordHeader... headers)	Add headers for the Kafka record
static <K> OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>	OutgoingKafkaRecordMetadata.builder()	Gets a OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder that can be used to construct instances of OutgoingKafkaRecordMetadata
static <K> OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>	OutgoingKafkaRecordMetadata.from(OutgoingKafkaRecordMetadata<K> other)
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>	OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder.withHeaders(List<org.apache.kafka.common.header.internals.RecordHeader> headers)	Specify the headers for the Kafka record
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>	OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder.withHeaders(org.apache.kafka.common.header.Headers headers)	Specify headers for the Kafka record
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>	OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder.withKey(K recordKey)	Set the Kafka record key
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>	OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder.withPartition(int partition)	In most cases Kafka's partitioner should be used to chose the Kafka partition.
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>	OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder.withTimestamp(Instant timestamp)	Specify the timestamp for the Kafka record
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder<K>	OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder.withTopic(String topic)	By default the hardcoded topic in the configuration is used.