Package io.smallrye.reactive.messaging.kafka.commit

Interface Summary

Interface	Description
KafkaCommitHandler

Class Summary

Class	Description
ContextHolder	A class holding a vert.x context to make sure methods are always run from the same one.
KafkaIgnoreCommit	Ignores an ACK and does not commit any offsets.
KafkaLatestCommit	Will commit the record offset received by the Kafka consumer (if higher than the previously committed offset).
KafkaThrottledLatestProcessedCommit	Will keep track of received messages and commit to the next offset after the latest ACKed message in sequence.

Enum Summary

Enum	Description
KafkaCommitHandler.Strategy

Exception Summary

Exception	Description
KafkaThrottledLatestProcessedCommit.TooManyMessagesWithoutAckException