Package | Description |
---|---|
io.smallrye.reactive.messaging.kafka.commit |
Modifier and Type | Class and Description |
---|---|
class |
KafkaLatestCommit
Will commit the record offset received by the Kafka consumer (if higher than the previously committed offset).
|
class |
KafkaThrottledLatestProcessedCommit
Will keep track of received messages and commit to the next offset after the latest
ACKed message in sequence.
|
Copyright © 2018–2021 SmallRye. All rights reserved.