public enum KafkaError extends Enum<KafkaError>
Modifier and Type | Method and Description |
---|---|
static KafkaError |
getError(int errorCode) |
static KafkaError |
valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static KafkaError[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final KafkaError NO_ERROR
public static final KafkaError OFFSET_OUT_OF_RANGE
public static final KafkaError INVALID_MESSAGE
public static final KafkaError UNKNOWN_TOPIC_OR_PARTITION
public static final KafkaError INVALID_FETCH_SIZE
public static final KafkaError LEADER_NOT_AVAILABLE
public static final KafkaError NOT_LEADER_FOR_PARTITION
public static final KafkaError REQUEST_TIMED_OUT
public static final KafkaError BROKER_NOT_AVAILABLE
public static final KafkaError REPLICA_NOT_AVAILABLE
public static final KafkaError MESSAGE_SIZE_TOO_LARGE
public static final KafkaError STALE_CONTROLLER_EPOCH
public static final KafkaError OFFSET_METADATA_TOO_LARGE
public static final KafkaError UNKNOWN
public static KafkaError[] values()
for (KafkaError c : KafkaError.values()) System.out.println(c);
public static KafkaError 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 static KafkaError getError(int errorCode)
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.