Uses of Class
io.smallrye.reactive.messaging.kafka.OutgoingKafkaRecordMetadata
-
Packages that use OutgoingKafkaRecordMetadata Package Description io.smallrye.reactive.messaging.kafka io.smallrye.reactive.messaging.kafka.impl.ce -
-
Uses of OutgoingKafkaRecordMetadata in io.smallrye.reactive.messaging.kafka
Methods in io.smallrye.reactive.messaging.kafka that return OutgoingKafkaRecordMetadata Modifier and Type Method Description OutgoingKafkaRecordMetadata<K>OutgoingKafkaRecordMetadata.OutgoingKafkaRecordMetadataBuilder. build() -
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)
-