THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
The reason is added as an argument to removeMembersFromConsumerGroup optional attribute to RemoveMembersFromConsumerGroupOptions class which is used by the Admin#removeMembersFromConsumerGroup method.
Code Block | ||
---|---|---|
| ||
/** * Remove members from the consumer group by given member identities. * <p> * For possible error codes, refer to {@link LeaveGroupResponse}. * * @param groupId The ID of the group to remove member from. * @param reason The reason why the member left the group. * @param options The options to carry removing members' information. * @return The MembershipChangeResult. */ RemoveMembersFromConsumerGroupResult removeMembersFromConsumerGroup(String groupId, String reason, RemoveMembersFromConsumerGroupOptions options);@InterfaceStability.Evolving public class RemoveMembersFromConsumerGroupOptions extends AbstractOptions<RemoveMembersFromConsumerGroupOptions> { /** * Sets an optional reason. */ void setReason(final String reason); /** * Returns the optional reason or an empty String if not defined. */ String reason(); } |
Consumer API
The reason is added as an argument to enforceRebalance method.
Code Block | ||
---|---|---|
| ||
/**
* @see KafkaConsumer#enforceRebalance()
*/
void enforceRebalance(final String reason); |
Proposed Changes
...