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
io.smallrye.reactive.messaging.kafka.health
io.smallrye.reactive.messaging.kafka.impl

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 KafkaThrottledLatestProcessedCommit	KafkaThrottledLatestProcessedCommit.create(io.vertx.mutiny.core.Vertx vertx, ReactiveKafkaConsumer<?,?> 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 KafkaFailureHandler	KafkaDeadLetterQueue.create(Map<String,?> kafkaConfiguration, KafkaConnectorIncomingConfiguration conf, KafkaSource<?,?> source, KafkaCDIEvents kafkaCDIEvents)

Constructors in io.smallrye.reactive.messaging.kafka.fault with parameters of type KafkaSource

Constructor	Description
DeserializerWrapper(String className, boolean key, DeserializationFailureHandler<T> failureHandler, KafkaSource<?,?> source, boolean failByDefault)
KafkaDeadLetterQueue(String channel, String topic, ReactiveKafkaProducer producer, KafkaSource<?,?> source)
KafkaFailStop(String channel, KafkaSource<?,?> source)

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

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

Constructor	Description
KafkaSourceHealth(KafkaSource<?,?> source, KafkaConnectorIncomingConfiguration config, ReactiveKafkaConsumer<?,?> client)

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

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

Constructor	Description
ReactiveKafkaConsumer(KafkaConnectorIncomingConfiguration config, KafkaSource<K,V> source)