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 and 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 and 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 and 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 and Description
ReactiveKafkaConsumer<K,V>	KafkaSource.getConsumer() For testing purpose only

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

Constructor and Description
KafkaRecordStream(ReactiveKafkaConsumer<K,V> client, KafkaConnectorIncomingConfiguration config, io.vertx.core.Context context)