Repository: kafka Updated Branches: refs/heads/trunk aa365639b -> 157fba840
KAFKA-2117; Use the correct metadata field for reading offset struct; reviewed by Jun Rao and Jiangjie Qin Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/157fba84 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/157fba84 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/157fba84 Branch: refs/heads/trunk Commit: 157fba840759e39bc1422fdca2597e2d9a77bfb2 Parents: aa36563 Author: Guozhang Wang <[email protected]> Authored: Mon Apr 13 18:41:33 2015 -0700 Committer: Guozhang Wang <[email protected]> Committed: Mon Apr 13 18:41:33 2015 -0700 ---------------------------------------------------------------------- core/src/main/scala/kafka/server/OffsetManager.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/157fba84/core/src/main/scala/kafka/server/OffsetManager.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/kafka/server/OffsetManager.scala b/core/src/main/scala/kafka/server/OffsetManager.scala index 420e2c3..18680ce 100755 --- a/core/src/main/scala/kafka/server/OffsetManager.scala +++ b/core/src/main/scala/kafka/server/OffsetManager.scala @@ -573,7 +573,7 @@ object OffsetManager { OffsetAndMetadata(offset, metadata, timestamp) } else if (structAndVersion.version == 1) { val offset = structAndVersion.value.get(VALUE_OFFSET_FIELD_V1).asInstanceOf[Long] - val metadata = structAndVersion.value.get(VALUE_OFFSET_FIELD_V1).asInstanceOf[String] + val metadata = structAndVersion.value.get(VALUE_METADATA_FIELD_V1).asInstanceOf[String] val commitTimestamp = structAndVersion.value.get(VALUE_COMMIT_TIMESTAMP_FIELD_V1).asInstanceOf[Long] val expireTimestamp = structAndVersion.value.get(VALUE_EXPIRE_TIMESTAMP_FIELD_V1).asInstanceOf[Long]
