Uses of Class
io.smallrye.reactive.messaging.kafka.KafkaConnectorOutgoingConfiguration

Packages that use KafkaConnectorOutgoingConfiguration

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

Uses of KafkaConnectorOutgoingConfiguration in io.smallrye.reactive.messaging.kafka.health

Constructors in io.smallrye.reactive.messaging.kafka.health with parameters of type KafkaConnectorOutgoingConfiguration

Constructor and Description
KafkaSinkReadinessHealth(io.vertx.mutiny.core.Vertx vertx, KafkaConnectorOutgoingConfiguration config, Map<String,Object> kafkaConfiguration, org.apache.kafka.clients.producer.Producer<?,?> producer)

Uses of KafkaConnectorOutgoingConfiguration in io.smallrye.reactive.messaging.kafka.impl

Constructors in io.smallrye.reactive.messaging.kafka.impl with parameters of type KafkaConnectorOutgoingConfiguration

Constructor and 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 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)