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/trunk Commit: dc0de292531f0af0a0eba71d170c7bd2706500d8 Parents: 492ed7a Author: Milosz Tanski <mil...@adfin.com> Authored: Wed May 29 21:43:41 2013 -0700 Committer: Jun Rao <jun...@gmail.com> Committed: Wed May 29 21:43:41 2013 -0700 ---------------------------------------------------------------------- core/src/main/scala/kafka/api/OffsetRequest.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- 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) } }
