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 java.lang.Object

Constants for the ack setting for the client, which impacts message delivery durability.

See Also:

ProducerConfig.ACKS_DOC

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
Acknowledge()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT

public static final int DEFAULT

Relay on the default behaviour.

See Also:

Constant Field Values

NONE

public static final int NONE

Don't wait for the server to acknowledge receipt.

See Also:

Constant Field Values

ONE

public static final int ONE

Wait for the leader to acknowledge.

See Also:

Constant Field Values

ALL

public static final int ALL

Wait for a full set of in-sync replicas to acknowledge.

See Also:

Constant Field Values

Constructor Detail

Acknowledge

public Acknowledge()