Uses of Class
io.smallrye.reactive.messaging.kafka.KafkaConnectorOutgoingConfiguration
-
Packages that use KafkaConnectorOutgoingConfiguration Package Description io.smallrye.reactive.messaging.kafka.impl io.smallrye.reactive.messaging.kafka.impl.ce -
-
Uses of KafkaConnectorOutgoingConfiguration in io.smallrye.reactive.messaging.kafka.impl
Constructors in io.smallrye.reactive.messaging.kafka.impl with parameters of type KafkaConnectorOutgoingConfiguration Constructor Description KafkaSink(io.vertx.mutiny.core.Vertx vertx, KafkaConnectorOutgoingConfiguration config, KafkaCDIEvents kafkaCDIEvents) -
Uses of KafkaConnectorOutgoingConfiguration in io.smallrye.reactive.messaging.kafka.impl.ce
Methods in io.smallrye.reactive.messaging.kafka.impl.ce with parameters of type KafkaConnectorOutgoingConfiguration 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)
-