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 Description class
OutgoingKafkaRecordMetadata<K>
Deprecated.useOutgoingKafkaRecordMetadata
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 Description OutgoingKafkaRecordMetadata<K>
OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder. build()
Create theOutgoingKafkaRecordMetadata
instance based on the values set in this builderMethods in io.smallrye.reactive.messaging.kafka.api with parameters of type OutgoingKafkaRecordMetadata Modifier and Type Method Description static <T,K>
Message<T>KafkaMetadataUtil. writeOutgoingKafkaMetadata(Message<T> msg, OutgoingKafkaRecordMetadata<K> outgoingKafkaRecordMetadata)
WriteOutgoingKafkaRecordMetadata
to aMessage
. -
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 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)
-