Browse Source

MINOR: Add api version to uncaught exception message (#7311)

When we have an unhandled exception in the request handler, we print some details about the request such as the api key and payload. It is also useful to see the version of the request which is not always apparent from the request payload.

Reviewers: Guozhang Wang <wangguoz@gmail.com>
pull/7322/head
Jason Gustafson 5 years ago committed by GitHub
parent
commit
41b89a6ecf
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 1
      core/src/main/scala/kafka/server/KafkaApis.scala

1
core/src/main/scala/kafka/server/KafkaApis.scala

@ -2683,6 +2683,7 @@ class KafkaApis(val requestChannel: RequestChannel,
s"clientId=${request.header.clientId}, " + s"clientId=${request.header.clientId}, " +
s"correlationId=${request.header.correlationId}, " + s"correlationId=${request.header.correlationId}, " +
s"api=${request.header.apiKey}, " + s"api=${request.header.apiKey}, " +
s"version=${request.header.apiVersion}, " +
s"body=${request.body[AbstractRequest]}", e) s"body=${request.body[AbstractRequest]}", e)
if (mayThrottle) if (mayThrottle)
sendErrorResponseMaybeThrottle(request, e) sendErrorResponseMaybeThrottle(request, e)

Loading…
Cancel
Save