Class KafkaLatestCommit

  • All Implemented Interfaces:
    KafkaCommitHandler

    public class KafkaLatestCommit
    extends ContextHolder
    implements KafkaCommitHandler
    Will commit the record offset received by the Kafka consumer (if higher than the previously committed offset). This offset may be greater than the currently ACKed message.

    This handler is the default when `enable.auto.commit` is `false`. This strategy provides at-least-once delivery if the channel processes the message without performing any asynchronous processing.

    This strategy should not be used on high-load as offset commit is expensive.

    To use set `commit-strategy` to `latest`.

    • Constructor Detail

      • KafkaLatestCommit

        public KafkaLatestCommit​(io.vertx.mutiny.core.Vertx vertx,
                                 io.vertx.mutiny.kafka.client.consumer.KafkaConsumer<?,​?> consumer)