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
KafkaSinkHealth(KafkaConnectorOutgoingConfiguration config, Map<String,?> 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(KafkaConnectorOutgoingConfiguration config, KafkaCDIEvents kafkaCDIEvents)
ReactiveKafkaProducer(KafkaConnectorOutgoingConfiguration config)

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)