| 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.