Uses of Class
io.smallrye.reactive.messaging.kafka.impl.KafkaSource
-
Packages that use KafkaSource Package Description io.smallrye.reactive.messaging.kafka.commit io.smallrye.reactive.messaging.kafka.fault -
-
Uses of KafkaSource in io.smallrye.reactive.messaging.kafka.commit
Methods in io.smallrye.reactive.messaging.kafka.commit with parameters of type KafkaSource Modifier and Type Method Description static KafkaThrottledLatestProcessedCommitKafkaThrottledLatestProcessedCommit. create(io.vertx.mutiny.core.Vertx vertx, io.vertx.mutiny.kafka.client.consumer.KafkaConsumer<?,?> consumer, String groupId, KafkaConnectorIncomingConfiguration config, KafkaSource<?,?> source) -
Uses of KafkaSource in io.smallrye.reactive.messaging.kafka.fault
Methods in io.smallrye.reactive.messaging.kafka.fault with parameters of type KafkaSource Modifier and Type Method Description static KafkaFailureHandlerKafkaDeadLetterQueue. create(io.vertx.mutiny.core.Vertx vertx, Map<String,String> kafkaConfiguration, KafkaConnectorIncomingConfiguration conf, KafkaSource<?,?> source, KafkaCDIEvents kafkaCDIEvents)Constructors in io.smallrye.reactive.messaging.kafka.fault with parameters of type KafkaSource Constructor Description KafkaDeadLetterQueue(String channel, String topic, io.vertx.mutiny.kafka.client.producer.KafkaProducer producer, KafkaSource<?,?> source)KafkaFailStop(String channel, KafkaSource<?,?> source)
-