Uses of Class
io.smallrye.reactive.messaging.kafka.commit.KafkaThrottledLatestProcessedCommit

Packages that use KafkaThrottledLatestProcessedCommit

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

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

Methods in io.smallrye.reactive.messaging.kafka.commit that return KafkaThrottledLatestProcessedCommit

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