DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
| Code Block |
|---|
{
"apiKey": 93,
"type": "response",
"name": "UnregisterControllerResponse",
"validVersions": "0",
"flexibleVersions": "0+",
"fields": [
{ "name": "ThrottleTimeMs", "type": "int32", "versions": "0+",
"about": "Duration in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota." },
{ "name": "ErrorCode", "type": "int16", "versions": "0+",
"about": "The error code, or 0 if there was no error." },
{ "name": "ErrorMessage", "type": "string", "versions": "0+", "nullableVersions": "0+",
"about": "The top-level error message, or `null` if there was no top-level error." }
]
} |
Public APIs
Admin.java
| Code Block |
|---|
/**
* Unregister a controller.
*
* This is a convenience method for {@link #unregisterController(int, UnregisterControllerOptions)}
*
* @param controllerId the controller id to unregister.
*
* @return the {@link UnregisterControllerResult} containing the result
*/
default UnregisterControllerResult unregisterController(int controllerId) {
return unregisterController(controllerId, new UnregisterControllerOptions());
}
/**
* Unregister a controller.
*
* The following exceptions can be anticipated when calling {@code get()} on the future from the
* returned {@link UnregisterControllerResult}:
* <ul>
* <li>{@link org.apache.kafka.common.errors.TimeoutException}
* If the request timed out before the describe operation could finish.</li>
* <li>{@link org.apache.kafka.common.errors.UnsupportedVersionException}
* If the software is too old to support the unregistration API.
* </ul>
* <p>
*
* @param controllerId the controller id to unregister.
* @param options the options to use.
*
* @return the {@link UnregisterControllerResult} containing the result
*/
UnregisterControllerResult unregisterController(int controllerId, UnregisterControllerOptions options); |
New Metadata Record
UnregisterControllerRecord
...