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