THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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:
| Code Block | ||
|---|---|---|
| ||
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
...