Uses of Interface
io.smallrye.reactive.messaging.kafka.commit.KafkaCommitHandler

Packages that use KafkaCommitHandler

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

Uses of KafkaCommitHandler in io.smallrye.reactive.messaging.kafka

Constructors in io.smallrye.reactive.messaging.kafka with parameters of type KafkaCommitHandler

Constructor and Description
IncomingKafkaRecord(org.apache.kafka.clients.consumer.ConsumerRecord<K,T> record, KafkaCommitHandler commitHandler, KafkaFailureHandler onNack, boolean cloudEventEnabled, boolean tracingEnabled)

Uses of KafkaCommitHandler in io.smallrye.reactive.messaging.kafka.commit

Classes in io.smallrye.reactive.messaging.kafka.commit that implement KafkaCommitHandler

Modifier and Type	Class and Description
class	KafkaIgnoreCommit Ignores an ACK and does not commit any offsets.
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.

Uses of KafkaCommitHandler in io.smallrye.reactive.messaging.kafka.impl

Methods in io.smallrye.reactive.messaging.kafka.impl that return KafkaCommitHandler

Modifier and Type	Method and Description
KafkaCommitHandler	KafkaSource.getCommitHandler()