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	Description
IncomingKafkaRecord(org.apache.kafka.clients.consumer.ConsumerRecord<K,T> record, KafkaCommitHandler commitHandler, KafkaFailureHandler onNack, boolean cloudEventEnabled, boolean tracingEnabled)
IncomingKafkaRecordBatch(org.apache.kafka.clients.consumer.ConsumerRecords<K,T> records, 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	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	Description
KafkaCommitHandler	KafkaSource.getCommitHandler()