public enum PartitionReassignmentsStatusV1 extends Enum<PartitionReassignmentsStatusV1>
FAILED
- when the broker removal operation failed midway.
It is unknown whether any replicas were moved away or not.
The user is expected to either retry the removal or cancel it.
2. PENDING
- when the partition reassignments plan is being computed. Reassignments are yet to happen.
3. IN_PROGRESS
- when the partitions are actively being reassigned.
4. CANCELED
- when the partition drain was cancelled because of unrelated factors, like the broker being restarted or the shutdown failing
5. COMPLETE
- when all the replicas of the to be removed broker were reassigned away from it.
If this status is returned, the broker to be removed has no replicas on it.Enum Constant and Description |
---|
CANCELED |
COMPLETE |
FAILED |
IN_PROGRESS |
PENDING |
Modifier and Type | Method and Description |
---|---|
static PartitionReassignmentsStatusV1 |
toOldStatus(org.apache.kafka.clients.admin.PartitionReassignmentsStatus newStatus)
Convert the new #
PartitionReassignmentsStatus to this
deprecated status. |
static PartitionReassignmentsStatusV1 |
valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static PartitionReassignmentsStatusV1[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final PartitionReassignmentsStatusV1 FAILED
public static final PartitionReassignmentsStatusV1 PENDING
public static final PartitionReassignmentsStatusV1 IN_PROGRESS
public static final PartitionReassignmentsStatusV1 CANCELED
public static final PartitionReassignmentsStatusV1 COMPLETE
public static PartitionReassignmentsStatusV1[] values()
for (PartitionReassignmentsStatusV1 c : PartitionReassignmentsStatusV1.values()) System.out.println(c);
public static PartitionReassignmentsStatusV1 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 PartitionReassignmentsStatusV1 toOldStatus(org.apache.kafka.clients.admin.PartitionReassignmentsStatus newStatus)
PartitionReassignmentsStatus
to this
deprecated status.