Jason Gustafson created KAFKA-14167:
---------------------------------------
Summary: Unexpected UNKNOWN_SERVER_ERROR raised from kraft
controller
Key: KAFKA-14167
URL: https://issues.apache.org/jira/browse/KAFKA-14167
Project: Kafka
Issue Type: Bug
Reporter: Jason Gustafson
In `ControllerApis`, we have callbacks such as the following after completion:
{code:java}
controller.allocateProducerIds(context, allocatedProducerIdsRequest.data)
.handle[Unit] { (results, exception) =>
if (exception != null) {
requestHelper.handleError(request, exception)
} else {
requestHelper.sendResponseMaybeThrottle(request, requestThrottleMs =>
{
results.setThrottleTimeMs(requestThrottleMs)
new AllocateProducerIdsResponse(results)
})
}
} {code}
What I see locally is that the underlying exception that gets passed to
`handle` always gets wrapped in a `CompletionException`. When passed to
`getErrorResponse`, this error will get converted to `UNKNOWN_SERVER_ERROR`.
For example, in this case, a `NOT_CONTROLLER` error returned from the
controller would be returned as `UNKNOWN_SERVER_ERROR`. It looks like there are
a few APIs that are potentially affected by this bug, such as `DeleteTopics`
and `UpdateFeatures`.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)