Package io.micronaut.configuration.kafka.annotation

Class KafkaClient.Acknowledge

java.lang.Object
io.micronaut.configuration.kafka.annotation.KafkaClient.Acknowledge
Enclosing class:
KafkaClient
public static class KafkaClient.Acknowledge extends Object
Constants for the ack setting for the client, which impacts message delivery durability.
See Also:

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final int
    ALL
    Wait for a full set of in-sync replicas to acknowledge.
    static final int
    DEFAULT
    Relay on the default behaviour.
    static final int
    NONE
    Don't wait for the server to acknowledge receipt.
    static final int
    ONE
    Wait for the leader to acknowledge.

  • Constructor Summary

    Constructors
    Constructor
    Description
    Acknowledge()
     

  • Method Summary

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Field Details

    • DEFAULT

      public static final int DEFAULT
      Relay on the default behaviour.
      See Also:

    • NONE

      public static final int NONE
      Don't wait for the server to acknowledge receipt.
      See Also:

    • ONE

      public static final int ONE
      Wait for the leader to acknowledge.
      See Also:

    • ALL

      public static final int ALL
      Wait for a full set of in-sync replicas to acknowledge.
      See Also:

  • Constructor Details

    • Acknowledge

      public Acknowledge()