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

Packages that use OutgoingKafkaRecordMetadata

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

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

Subclasses of OutgoingKafkaRecordMetadata in io.smallrye.reactive.messaging.kafka

Modifier and Type	Class and Description
class	OutgoingKafkaRecordMetadata<K> Deprecated. use OutgoingKafkaRecordMetadata instead

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

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

Modifier and Type	Method and Description
OutgoingKafkaRecordMetadata<K>	OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder.build() Create the OutgoingKafkaRecordMetadata instance based on the values set in this builder

Methods in io.smallrye.reactive.messaging.kafka.api with parameters of type OutgoingKafkaRecordMetadata

Modifier and Type	Method and Description
static <T,K> Message<T>	KafkaMetadataUtil.writeOutgoingKafkaMetadata(Message<T> msg, OutgoingKafkaRecordMetadata<K> outgoingKafkaRecordMetadata) Write OutgoingKafkaRecordMetadata to a Message.

Uses of OutgoingKafkaRecordMetadata in io.smallrye.reactive.messaging.kafka.impl.ce

Methods in io.smallrye.reactive.messaging.kafka.impl.ce with parameters of type OutgoingKafkaRecordMetadata

Modifier and Type	Method and Description
static org.apache.kafka.clients.producer.ProducerRecord<?,?>	KafkaCloudEventHelper.createBinaryRecord(Message<?> message, String topic, OutgoingKafkaRecordMetadata<?> metadata, OutgoingCloudEventMetadata<?> ceMetadata, KafkaConnectorOutgoingConfiguration configuration)
static org.apache.kafka.clients.producer.ProducerRecord<?,?>	KafkaCloudEventHelper.createStructuredRecord(Message<?> message, String topic, OutgoingKafkaRecordMetadata<?> metadata, OutgoingCloudEventMetadata<?> ceMetadata, KafkaConnectorOutgoingConfiguration configuration)