Package | Description |
---|---|
io.smallrye.reactive.messaging.kafka | |
io.smallrye.reactive.messaging.kafka.commit | |
io.smallrye.reactive.messaging.kafka.impl |
Class and Description |
---|
KafkaCommitHandler |
Class and 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.
|
Class and Description |
---|
KafkaCommitHandler |
Copyright © 2018–2021 SmallRye. All rights reserved.