kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: KAFKA-2117; Use the correct metadata field for reading offset struct; reviewed by Jun Rao and Jiangjie Qin
Date Tue, 14 Apr 2015 01:41:38 GMT
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 <wangguoz@gmail.com>
Authored: Mon Apr 13 18:41:33 2015 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
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]
 


Mime
View raw message