diff --git a/core/src/main/scala/kafka/tools/DumpLogSegments.scala b/core/src/main/scala/kafka/tools/DumpLogSegments.scala index 6daf87b..54f6093 100644 --- a/core/src/main/scala/kafka/tools/DumpLogSegments.scala +++ b/core/src/main/scala/kafka/tools/DumpLogSegments.scala @@ -141,8 +141,8 @@ object DumpLogSegments { lastOffset = messageAndOffset.offset print("offset: " + messageAndOffset.offset + " position: " + validBytes + " isvalid: " + msg.isValid + - " payloadsize: " + msg.payloadSize + " magic: " + msg.magic + - " compresscodec: " + msg.compressionCodec + " crc: " + msg.checksum) + " payloadsize: " + msg.payloadSize + " magic: " + msg.magic + " txId: " + msg.txId + + " txControl: " + msg.txControl + " compresscodec: " + msg.compressionCodec + " crc: " + msg.checksum) if(msg.hasKey) print(" keysize: " + msg.keySize) if(printContents) {