trivial fix to print key properly in DumpLogSegments
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/06911384 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/06911384 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/06911384 Branch: refs/heads/trunk Commit: 06911384f2f32fe17a3057c9830e3f7dc30d66e6 Parents: 68528da Author: Jun Rao <[email protected]> Authored: Fri Mar 29 13:24:45 2013 -0700 Committer: Jun Rao <[email protected]> Committed: Fri Mar 29 13:24:45 2013 -0700 ---------------------------------------------------------------------- core/src/main/scala/kafka/tools/DumpLogSegments.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/06911384/core/src/main/scala/kafka/tools/DumpLogSegments.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/kafka/tools/DumpLogSegments.scala b/core/src/main/scala/kafka/tools/DumpLogSegments.scala index 06e6437..dc3dcdf 100644 --- a/core/src/main/scala/kafka/tools/DumpLogSegments.scala +++ b/core/src/main/scala/kafka/tools/DumpLogSegments.scala @@ -145,7 +145,7 @@ object DumpLogSegments { print(" keysize: " + msg.keySize) if(printContents) { if(msg.hasKey) - print(" key: " + Utils.readString(messageAndOffset.message.payload, "UTF-8")) + print(" key: " + Utils.readString(messageAndOffset.message.key, "UTF-8")) print(" payload: " + Utils.readString(messageAndOffset.message.payload, "UTF-8")) } println()
