public static enum ConsumerPartitionAssignor.RebalanceProtocol extends java.lang.Enum<ConsumerPartitionAssignor.RebalanceProtocol>
ConsumerPartitionAssignor
implementors can claim supporting one or more rebalance protocols via the
ConsumerPartitionAssignor.supportedProtocols()
, and it is their responsibility to respect the rules
of those protocols in their ConsumerPartitionAssignor.assign(Cluster, GroupSubscription)
implementations.
Failures to follow the rules of the supported protocols would lead to runtime error or undefined behavior.
The EAGER
rebalance protocol requires a consumer to always revoke all its owned
partitions before participating in a rebalance event. It therefore allows a complete reshuffling of the assignment.
COOPERATIVE
rebalance protocol allows a consumer to retain its currently owned
partitions before participating in a rebalance event. The assignor should not reassign any owned partitions
immediately, but instead may indicate consumers the need for partition revocation so that the revoked
partitions can be reassigned to other consumers in the next rebalance event. This is designed for sticky assignment
logic which attempts to minimize partition reassignment with cooperative adjustments.Enum Constant and Description |
---|
COOPERATIVE |
EAGER |
Modifier and Type | Method and Description |
---|---|
static ConsumerPartitionAssignor.RebalanceProtocol |
forId(byte id) |
byte |
id() |
static ConsumerPartitionAssignor.RebalanceProtocol |
valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static ConsumerPartitionAssignor.RebalanceProtocol[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final ConsumerPartitionAssignor.RebalanceProtocol EAGER
public static final ConsumerPartitionAssignor.RebalanceProtocol COOPERATIVE
public static ConsumerPartitionAssignor.RebalanceProtocol[] values()
for (ConsumerPartitionAssignor.RebalanceProtocol c : ConsumerPartitionAssignor.RebalanceProtocol.values()) System.out.println(c);
public static ConsumerPartitionAssignor.RebalanceProtocol valueOf(java.lang.String name)
name
- the name of the enum constant to be returned.java.lang.IllegalArgumentException
- if this enum type has no constant with the specified namejava.lang.NullPointerException
- if the argument is nullpublic byte id()
public static ConsumerPartitionAssignor.RebalanceProtocol forId(byte id)