kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject git commit: kafka-856; Correlation id for OffsetFetch request (#2) always responds with 0; patched by Milosz Tanski; reviewed by Jun Rao
Date Thu, 30 May 2013 04:44:01 GMT
Updated Branches:
  refs/heads/0.8 492ed7a35 -> dc0de2925


kafka-856; Correlation id for OffsetFetch request (#2) always responds with 0; patched by
Milosz Tanski; reviewed by Jun Rao


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/dc0de292
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/dc0de292
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/dc0de292

Branch: refs/heads/0.8
Commit: dc0de292531f0af0a0eba71d170c7bd2706500d8
Parents: 492ed7a
Author: Milosz Tanski <milosz@adfin.com>
Authored: Wed May 29 21:43:41 2013 -0700
Committer: Jun Rao <junrao@gmail.com>
Committed: Wed May 29 21:43:41 2013 -0700

----------------------------------------------------------------------
 core/src/main/scala/kafka/api/OffsetRequest.scala |    2 +-
 1 files changed, 1 insertions(+), 1 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/dc0de292/core/src/main/scala/kafka/api/OffsetRequest.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/api/OffsetRequest.scala b/core/src/main/scala/kafka/api/OffsetRequest.scala
index 32ebfd4..0a94a6c 100644
--- a/core/src/main/scala/kafka/api/OffsetRequest.scala
+++ b/core/src/main/scala/kafka/api/OffsetRequest.scala
@@ -49,7 +49,7 @@ object OffsetRequest {
         (TopicAndPartition(topic, partitionId), PartitionOffsetRequestInfo(time, maxNumOffsets))
       })
     })
-    OffsetRequest(Map(pairs:_*), versionId = versionId, clientId = clientId, replicaId =
replicaId)
+    OffsetRequest(Map(pairs:_*), versionId= versionId, clientId = clientId, correlationId
= correlationId, replicaId = replicaId)
   }
 }
 


Mime
View raw message