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

Packages that use KafkaCDIEvents

Package	Description
io.smallrye.reactive.messaging.kafka.fault
io.smallrye.reactive.messaging.kafka.impl

Uses of KafkaCDIEvents in io.smallrye.reactive.messaging.kafka.fault

Methods in io.smallrye.reactive.messaging.kafka.fault with parameters of type KafkaCDIEvents

Modifier and Type	Method and Description
static KafkaFailureHandler	KafkaDeadLetterQueue.create(io.vertx.mutiny.core.Vertx vertx, Map<String,?> kafkaConfiguration, KafkaConnectorIncomingConfiguration conf, KafkaSource<?,?> source, KafkaCDIEvents kafkaCDIEvents)

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

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

Constructor and Description
KafkaSink(io.vertx.mutiny.core.Vertx vertx, KafkaConnectorOutgoingConfiguration config, KafkaCDIEvents kafkaCDIEvents)
KafkaSource(io.vertx.mutiny.core.Vertx vertx, String consumerGroup, KafkaConnectorIncomingConfiguration config, javax.enterprise.inject.Instance<KafkaConsumerRebalanceListener> consumerRebalanceListeners, KafkaCDIEvents kafkaCDIEvents, javax.enterprise.inject.Instance<DeserializationFailureHandler<?>> deserializationFailureHandlers, int index)