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
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
public class DescribeFeaturesOptions extends AbstractOptions<DescribeFeaturesOptions> {
private Optional<Integer>OptionalInt nodeId = OptionalOptionalInt.empty();
/**
* Set the node id to which the request should be sent.
*/
public DescribeFeaturesOptions nodeId(int nodeId) {
this.nodeId = OptionalOptionalInt.of(nodeId);
return this;
}
/**
* The node id to which the request should be sent. If using bootstrap controller and the node id is empty,
* the request will be sent to the controller node. If using bootstrap broker and node id is empty, the
* request will be sent to the first available nodearbitrary controller/broker.
*/
public Optional<Integer>OptionalInt nodeId() {
return nodeId;
}
} |
...
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.