Index: core/src/test/resources/log4j.properties
===================================================================
--- core/src/test/resources/log4j.properties	(revision 1161279)
+++ core/src/test/resources/log4j.properties	(working copy)
@@ -1,9 +1,10 @@
-log4j.rootLogger=OFF, stdout
+log4j.rootLogger=WARN, stdout
 
 log4j.appender.stdout=org.apache.log4j.ConsoleAppender
 log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
-log4j.appender.stdout.layout.ConversionPattern=[%d] %p %m (%c)%n
+log4j.appender.stdout.layout.ConversionPattern=[%d] %p %m (%c:%L)%n
 
-# Turn on all our debugging info
-log4j.logger.kafka=OFF
+log4j.logger.kafka=WARN
 
+# zkclient can be verbose, during debugging it is common to adjust is separately
+log4j.logger.org.I0Itec.zkclient.ZkClient=WARN
\ No newline at end of file
Index: core/src/main/scala/kafka/tools/DumpLogSegments.scala
===================================================================
--- core/src/main/scala/kafka/tools/DumpLogSegments.scala	(revision 1161279)
+++ core/src/main/scala/kafka/tools/DumpLogSegments.scala	(working copy)
@@ -37,14 +37,11 @@
         println("Starting offset: " + offset)
         val messageSet = new FileMessageSet(file, false)
         for(messageAndOffset <- messageSet) {
-          println("----------------------------------------------")
-         if (messageAndOffset.message.isValid)
-            println("offset:\t" + offset)
-          else
-            println("offset:\t %d \t invalid".format(offset))
+          val msg = messageAndOffset.message
+          println("offset: " + offset + " isvalid: " + msg.isValid + " magic: " + msg.magic + " compresscodec: " + msg.compressionCodec)
           if (!isNoPrint)
             println("payload:\t" + Utils.toString(messageAndOffset.message.payload, "UTF-8"))
-          offset = messageAndOffset.offset
+          offset += messageAndOffset.offset
         }
       }
     }