Index: core/src/main/scala/kafka/server/KafkaRequestHandlers.scala =================================================================== --- core/src/main/scala/kafka/server/KafkaRequestHandlers.scala (revision 1160521) +++ core/src/main/scala/kafka/server/KafkaRequestHandlers.scala (working copy) @@ -64,7 +64,7 @@ def handleMultiProducerRequest(receive: Receive): Option[Send] = { val request = MultiProducerRequest.readFrom(receive.buffer) if(requestLogger.isTraceEnabled) - requestLogger.trace("Multiproducer request ") + requestLogger.trace("Multiproducer request " + request.toString) request.produces.map(handleProducerRequest(_, "MultiProducerRequest")) None }