public static enum KafkaPublisher.Ack extends Enum<KafkaPublisher.Ack>
Enum Constant and Description |
---|
ALL_RECEIVED
Waits for all replicas received data.
|
FIRE_AND_FORGET
Not wait for ack.
|
LEADER_RECEIVED
Waits for the leader received data.
|
Modifier and Type | Method and Description |
---|---|
int |
getAck()
Returns the numerical ack number as understand by Kafka server.
|
static KafkaPublisher.Ack |
valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static KafkaPublisher.Ack[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final KafkaPublisher.Ack FIRE_AND_FORGET
public static final KafkaPublisher.Ack LEADER_RECEIVED
public static final KafkaPublisher.Ack ALL_RECEIVED
public static KafkaPublisher.Ack[] values()
for (KafkaPublisher.Ack c : KafkaPublisher.Ack.values()) System.out.println(c);
public static KafkaPublisher.Ack valueOf(String name)
name
- the name of the enum constant to be returned.IllegalArgumentException
- if this enum type has no constant with the specified nameNullPointerException
- if the argument is nullpublic int getAck()
Copyright © 2013-2020 The Apache Software Foundation. All rights reserved.