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

Packages that use OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder

Package	Description
io.smallrye.reactive.messaging.kafka

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

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

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