kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject svn commit: r1181329 - /incubator/kafka/trunk/core/src/main/scala/kafka/tools/DumpLogSegments.scala
Date Tue, 11 Oct 2011 01:10:38 GMT
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



Mime
View raw message