diff --git a/core/src/main/scala/kafka/tools/DumpLogSegments.scala b/core/src/main/scala/kafka/tools/DumpLogSegments.scala index 53b525a..85ae0c5 100644 --- a/core/src/main/scala/kafka/tools/DumpLogSegments.scala +++ b/core/src/main/scala/kafka/tools/DumpLogSegments.scala @@ -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