diff --git a/core/src/main/scala/kafka/log/FileMessageSet.scala b/core/src/main/scala/kafka/log/FileMessageSet.scala index 2479a5f..6c099da 100644 --- a/core/src/main/scala/kafka/log/FileMessageSet.scala +++ b/core/src/main/scala/kafka/log/FileMessageSet.scala @@ -67,6 +67,11 @@ class FileMessageSet private[kafka](@volatile var file: File, */ def this(file: File) = this(file, Utils.openChannel(file, mutable = true)) + + /** + * Create a file message set with mutable option + */ + def this(file: File, mutable: Boolean) = this(file, Utils.openChannel(file, mutable)) /** * Create a slice view of the file message set that begins and ends at the given byte offsets diff --git a/core/src/main/scala/kafka/tools/DumpLogSegments.scala b/core/src/main/scala/kafka/tools/DumpLogSegments.scala index 5231e7c..89b6cb1 100644 --- a/core/src/main/scala/kafka/tools/DumpLogSegments.scala +++ b/core/src/main/scala/kafka/tools/DumpLogSegments.scala @@ -94,7 +94,7 @@ object DumpLogSegments { val startOffset = file.getName().split("\\.")(0).toLong val logFileName = file.getAbsolutePath.split("\\.")(0) + Log.LogFileSuffix val logFile = new File(logFileName) - val messageSet = new FileMessageSet(logFile) + val messageSet = new FileMessageSet(logFile, false) val index = new OffsetIndex(file = file, baseOffset = startOffset) for(i <- 0 until index.entries) { val entry = index.entry(i) @@ -120,7 +120,7 @@ object DumpLogSegments { isDeepIteration: Boolean) { val startOffset = file.getName().split("\\.")(0).toLong println("Starting offset: " + startOffset) - val messageSet = new FileMessageSet(file) + val messageSet = new FileMessageSet(file, false) var validBytes = 0L var lastOffset = -1l for(shallowMessageAndOffset <- messageSet) { // this only does shallow iteration