Uses of Package
io.smallrye.reactive.messaging.kafka.commit
-
Packages that use io.smallrye.reactive.messaging.kafka.commit Package Description io.smallrye.reactive.messaging.kafka io.smallrye.reactive.messaging.kafka.commit -
Classes in io.smallrye.reactive.messaging.kafka.commit used by io.smallrye.reactive.messaging.kafka Class Description KafkaCommitHandler -
Classes in io.smallrye.reactive.messaging.kafka.commit used by io.smallrye.reactive.messaging.kafka.commit Class Description ContextHolder A class holding a vert.x context to make sure methods are always run from the same one.KafkaCommitHandler KafkaCommitHandler.Strategy KafkaThrottledLatestProcessedCommit Will keep track of received messages and commit to the next offset after the latest ACKed message in sequence.