Browse Source

HOTFIX: ClassCastException in request logging

Author: Jason Gustafson <jason@confluent.io>

Reviewers: Colin P. Mccabe <cmccabe@confluent.io>, Ewen Cheslack-Postava <me@ewencp.org>

Closes #2566 from hachikuji/hotfix-request-logging
pull/2530/merge
Jason Gustafson 8 years ago
parent
commit
a515e93570
  1. 2
      core/src/main/scala/kafka/network/RequestChannel.scala

2
core/src/main/scala/kafka/network/RequestChannel.scala

@ -108,7 +108,7 @@ object RequestChannel extends Logging { @@ -108,7 +108,7 @@ object RequestChannel extends Logging {
if (requestObj != null)
requestObj.describe(details)
else
s"$header -- $body"
s"$header -- ${body[AbstractRequest]}"
}
def body[T <: AbstractRequest : ClassTag] = {

Loading…
Cancel
Save