Status

Current state: DraftAccepted

Discussion thread: here [Change the link from the KIP proposal email archive to your own email thread]

JIRA: here [Change the link from KAFKA-1 to your own ticket]

...

KafkaAdminClient will be updated to find all group coordinators in a single call if possible for both deleteConsumerGroups() and describeConsumerGroups(). If that's not possible, it will revert to send a FindCoordinators request for each group.

A new exception "NoBatchedFindCoordinatorsException" will be introduced:

package org.apache.kafka.common.errors;

/**
 * Indicates that it is not possible to lookup coordinators in batches with FindCoordinator. Instead
 * coordinators must be looked up one by one.
 */
public class NoBatchedFindCoordinatorsException extends UnsupportedVersionException {
    private static final long serialVersionUID = 1L;

    public NoBatchedFindCoordinatorsException(String message, Throwable cause) {
        super(message, cause);
    }

    public NoBatchedFindCoordinatorsException(String message) {
        super(message);
    }
}

This will be thrown by FindCoordinatorRequest when attempting to use v4 or above on brokers that don't support it.

Compatibility, Deprecation, and Migration Plan

...