Enum Class TaskAssignor.AssignmentError
java.lang.Object
java.lang.Enum<TaskAssignor.AssignmentError>
org.apache.kafka.streams.processor.assignment.TaskAssignor.AssignmentError
- All Implemented Interfaces:
Serializable,Comparable<TaskAssignor.AssignmentError>,Constable
- Enclosing interface:
TaskAssignor
NONE: no error detected ACTIVE_TASK_ASSIGNED_MULTIPLE_TIMES: multiple KafkaStreams clients assigned with the same active task INVALID_STANDBY_TASK: stateless task assigned as a standby task MISSING_PROCESS_ID: ProcessId present in the input ApplicationState was not present in the output TaskAssignment UNKNOWN_PROCESS_ID: unrecognized ProcessId not matching any of the participating consumers UNKNOWN_TASK_ID: unrecognized TaskId not matching any of the tasks to be assigned
Nested Class Summary
Nested classes/interfaces inherited from class java.lang.Enum
Enum.EnumDesc<E extends Enum<E>>Enum Constant Summary
Enum ConstantsEnum ConstantDescriptionMethod Summary
Modifier and TypeMethodDescriptionstatic TaskAssignor.AssignmentErrorReturns the enum constant of this class with the specified name.static TaskAssignor.AssignmentError[]values()Returns an array containing the constants of this enum class, in the order they are declared.Methods inherited from class java.lang.Enum
compareTo, describeConstable, equals, getDeclaringClass, hashCode, name, ordinal, toString, valueOf
Enum Constant Details
NONE
ACTIVE_TASK_ASSIGNED_MULTIPLE_TIMES
INVALID_STANDBY_TASK
MISSING_PROCESS_ID
UNKNOWN_PROCESS_ID
UNKNOWN_TASK_ID
Method Details
values
Returns an array containing the constants of this enum class, in the order they are declared.- Returns:
- an array containing the constants of this enum class, in the order they are declared
valueOf
Returns the enum constant of this class with the specified name. The string must match exactly an identifier used to declare an enum constant in this class. (Extraneous whitespace characters are not permitted.)- Parameters:
name- the name of the enum constant to be returned.- Returns:
- the enum constant with the specified name
- Throws:
IllegalArgumentException- if this enum class has no constant with the specified nameNullPointerException- if the argument is null