Package org.apache.kafka.streams.processor.assignment

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

public static enum TaskAssignor.AssignmentError
extends Enum<TaskAssignor.AssignmentError>

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 Constants

Enum Constant	Description
ACTIVE_TASK_ASSIGNED_MULTIPLE_TIMES
INVALID_STANDBY_TASK
MISSING_PROCESS_ID
NONE
UNKNOWN_PROCESS_ID
UNKNOWN_TASK_ID

Method Summary

Modifier and Type	Method	Description
static TaskAssignor.AssignmentError	valueOf(String name)	Returns 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

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Enum Constant Details

NONE

public static final TaskAssignor.AssignmentError NONE

ACTIVE_TASK_ASSIGNED_MULTIPLE_TIMES

public static final TaskAssignor.AssignmentError ACTIVE_TASK_ASSIGNED_MULTIPLE_TIMES

INVALID_STANDBY_TASK

public static final TaskAssignor.AssignmentError INVALID_STANDBY_TASK

MISSING_PROCESS_ID

public static final TaskAssignor.AssignmentError MISSING_PROCESS_ID

UNKNOWN_PROCESS_ID

public static final TaskAssignor.AssignmentError UNKNOWN_PROCESS_ID

UNKNOWN_TASK_ID

public static final TaskAssignor.AssignmentError UNKNOWN_TASK_ID

Method Details

values

public static TaskAssignor.AssignmentError[] 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

public static TaskAssignor.AssignmentError valueOf(String name)

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 name

NullPointerException - if the argument is null