From 46ce18162a19d901e1c6c1f67a375637273c694b Mon Sep 17 00:00:00 2001 From: Guozhang Wang Date: Mon, 13 Apr 2015 08:50:06 -0700 Subject: [PATCH] fix --- core/src/main/scala/kafka/server/OffsetManager.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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] -- 1.7.10.2 (Apple Git-33)