You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2011/10/11 03:10:38 UTC

svn commit: r1181329 - /incubator/kafka/trunk/core/src/main/scala/kafka/tools/DumpLogSegments.scala

Author: junrao
Date: Tue Oct 11 01:10:37 2011
New Revision: 1181329

URL: http://svn.apache.org/viewvc?rev=1181329&view=rev
Log:
Include payload size in DumpLogSegments; patched by Chris Burroughs; reviewed by Jun Rao; KAFKA-152

Modified:
    incubator/kafka/trunk/core/src/main/scala/kafka/tools/DumpLogSegments.scala

Modified: incubator/kafka/trunk/core/src/main/scala/kafka/tools/DumpLogSegments.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/core/src/main/scala/kafka/tools/DumpLogSegments.scala?rev=1181329&r1=1181328&r2=1181329&view=diff
==============================================================================
--- incubator/kafka/trunk/core/src/main/scala/kafka/tools/DumpLogSegments.scala (original)
+++ incubator/kafka/trunk/core/src/main/scala/kafka/tools/DumpLogSegments.scala Tue Oct 11 01:10:37 2011
@@ -39,7 +39,8 @@ object DumpLogSegments {
         val messageSet = new FileMessageSet(file, false)
         for(messageAndOffset <- messageSet) {
           val msg = messageAndOffset.message
-          println("offset: " + (startOffset + offset) + " isvalid: " + msg.isValid + " magic: " + msg.magic + " compresscodec: " + msg.compressionCodec)
+          println("offset: " + (startOffset + offset) + " isvalid: " + msg.isValid +
+                  " payloadsize: " + msg.payloadSize + " magic: " + msg.magic + " compresscodec: " + msg.compressionCodec)
           if (!isNoPrint)
             println("payload:\t" + Utils.toString(messageAndOffset.message.payload, "UTF-8"))
           offset = messageAndOffset.offset