kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: KAFKA-5355; DelayedFetch should propagate isolation level to log read
Date Sat, 03 Jun 2017 05:24:40 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.11.0 8ebe4838a -> 054e9740f


KAFKA-5355; DelayedFetch should propagate isolation level to log read

Tests will be added in a subsequent commit.

Author: Jason Gustafson <jason@confluent.io>

Reviewers: Ismael Juma <ismael@juma.me.uk>

Closes #3221 from hachikuji/KAFKA-5355

(cherry picked from commit 6a5a908b1cf972451ec8d5c66cf9fb4507a1355f)
Signed-off-by: Ismael Juma <ismael@juma.me.uk>


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

Branch: refs/heads/0.11.0
Commit: 054e9740f1bde193680bebb4329acabd509f0060
Parents: 8ebe483
Author: Jason Gustafson <jason@confluent.io>
Authored: Sat Jun 3 06:23:53 2017 +0100
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Sat Jun 3 06:24:51 2017 +0100

----------------------------------------------------------------------
 core/src/main/scala/kafka/server/DelayedFetch.scala | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/054e9740/core/src/main/scala/kafka/server/DelayedFetch.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/server/DelayedFetch.scala b/core/src/main/scala/kafka/server/DelayedFetch.scala
index 8c4731a..fb89800 100644
--- a/core/src/main/scala/kafka/server/DelayedFetch.scala
+++ b/core/src/main/scala/kafka/server/DelayedFetch.scala
@@ -152,7 +152,8 @@ class DelayedFetch(delayMs: Long,
       fetchMaxBytes = fetchMetadata.fetchMaxBytes,
       hardMaxBytesLimit = fetchMetadata.hardMaxBytesLimit,
       readPartitionInfo = fetchMetadata.fetchPartitionStatus.map { case (tp, status) =>
tp -> status.fetchInfo },
-      quota = quota
+      quota = quota,
+      isolationLevel = isolationLevel
     )
 
     val fetchPartitionData = logReadResults.map { case (tp, result) =>


Mime
View raw message