Package io.micronaut.configuration.kafka

Interface KafkaAcknowledgement

All Superinterfaces:
io.micronaut.messaging.Acknowledgement
public interface KafkaAcknowledgement extends io.micronaut.messaging.Acknowledgement
Defines an interface that can be injected into KafkaListener beans so that offsets can be manually committed.
Since:
1.1.0
Author:
James Kleeh

  • Method Summary

    Modifier and Type
    Method
    Description
    default void
    nack()
    Kafka does not support rejection of messages explicitly.

    Methods inherited from interface io.micronaut.messaging.Acknowledgement

    ack

  • Method Details

    • nack

      default void nack()
      Kafka does not support rejection of messages explicitly.
      Specified by:
      nack in interface io.micronaut.messaging.Acknowledgement
      Throws:
      UnsupportedOperationException - if called