DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
| Table of Contents |
|---|
Status
Current state: Under Discussion Accepted
Discussion thread: https://lists.apache.org/thread/mbjlgbv2q4x5ml7mx93ls77bg93wtrfy
...
Add nodeId to DescribeFeaturesOptions. Default value is -1empty.
| Code Block | ||||
|---|---|---|---|---|
| ||||
public class DescribeFeaturesOptions extends AbstractOptions<DescribeFeaturesOptions> {
private intOptionalInt nodeId = -1OptionalInt.empty();
/**
* Set the node id to which the request should be sent. If using bootstrap controller and node id is less than 0,
* the request will be sent to the controller node. If using bootstrap broker and node id is less than 0, the
* request will be sent to the first available node.
*/
public DescribeFeaturesOptions nodeId(int nodeId) {
this.nodeId = OptionalInt.of(nodeId);
return this;
}
/**
* The node id to which the request should be sent. If using bootstrap controller and the node id is less than 0empty,
* the request will be sent to the controller node. If using bootstrap broker and node id is less than 0, the
* request will be sent to the first available nodearbitrary controller/broker.
*/
public intOptionalInt nodeId() {
return nodeId;
}
} |
...
Default
DescribeFeaturesOptionscan work as usual.
If
nodeIdis negativeempty, the Admin client ignores it and falls back to useLeastLoadedBrokerOrActiveKController.
If
nodeIdis valid, the Admin client sendsApiVersionRequestto a node withnodeId.- If
nodeIdis not registered, the Admin client throws TimeoutException.
kafka-features.sh
The empty
—-node-idcan work as usual.
If
nodeIdis negative, the FeatureCommand throwsIllegalArgumentException.
If
nodeIdis valid, the FeatureCommand get getsApiVersionResponsefrom a node withnodeId.- If
nodeIdis not registered, the FeatureCommand throws AdminCommandFailedException.
...
Alternatives
N/AUse metrics to track finalized level and minimum / maximum supported level. The approach has been accepted in KIP-1180: Add generic feature level metrics.