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 classOutgoingKafkaRecordMetadata<K>Deprecated.useOutgoingKafkaRecordMetadatainstead -
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 theOutgoingKafkaRecordMetadatainstance 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)WriteOutgoingKafkaRecordMetadatato 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)
-