Uses of Class
io.smallrye.reactive.messaging.kafka.impl.ReactiveKafkaConsumer

Packages that use ReactiveKafkaConsumer

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

Uses of ReactiveKafkaConsumer in io.smallrye.reactive.messaging.kafka.commit

Methods in io.smallrye.reactive.messaging.kafka.commit with parameters of type ReactiveKafkaConsumer

Modifier and Type	Method	Description
static KafkaThrottledLatestProcessedCommit	KafkaThrottledLatestProcessedCommit.create(io.vertx.mutiny.core.Vertx vertx, ReactiveKafkaConsumer<?,?> consumer, String groupId, KafkaConnectorIncomingConfiguration config, KafkaSource<?,?> source)

Constructors in io.smallrye.reactive.messaging.kafka.commit with parameters of type ReactiveKafkaConsumer

Constructor	Description
KafkaLatestCommit(io.vertx.mutiny.core.Vertx vertx, KafkaConnectorIncomingConfiguration configuration, ReactiveKafkaConsumer<?,?> consumer)

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

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

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

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

Methods in io.smallrye.reactive.messaging.kafka.impl that return ReactiveKafkaConsumer

Modifier and Type	Method	Description
ReactiveKafkaConsumer<K,V>	KafkaSource.getConsumer()	For testing purpose only

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

Constructor	Description
KafkaRecordBatchStream(ReactiveKafkaConsumer<K,V> client, KafkaConnectorIncomingConfiguration config, io.vertx.core.Context context)
KafkaRecordStream(ReactiveKafkaConsumer<K,V> client, KafkaConnectorIncomingConfiguration config, io.vertx.core.Context context)
KafkaRecordStreamSubscription(ReactiveKafkaConsumer<K,V> client, KafkaConnectorIncomingConfiguration config, io.smallrye.mutiny.subscription.MultiSubscriber<? super T> subscriber, io.vertx.core.Context context, int maxPollRecords, BiConsumer<org.apache.kafka.clients.consumer.ConsumerRecords<K,V>,RecordQueue<T>> enqueueFunction)