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)
@@ -70,6 +70,8 @@
   }
 
   private def handleProducerRequest(request: ProducerRequest, requestHandlerName: String) = {
+    if(requestLogger.isTraceEnabled)
+      requestLogger.trace("Producer request " + request.toString)
     val partition = request.getTranslatedPartition(logManager.chooseRandomPartition)
     try {
       logManager.getOrCreateLog(request.topic, partition).append(request.messages)