Index: core/src/main/scala/kafka/tools/SimpleConsumerShell.scala =================================================================== --- core/src/main/scala/kafka/tools/SimpleConsumerShell.scala (revision 1400119) +++ core/src/main/scala/kafka/tools/SimpleConsumerShell.scala (working copy) @@ -186,7 +186,7 @@ var consumed = 0 for(messageAndOffset <- messageSet) { try { - offset = messageAndOffset.offset + offset = messageAndOffset.nextOffset if(printOffsets) System.out.println("next offset = " + offset) formatter.writeTo(messageAndOffset.message, System.out)