root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 3 Packages Projects Releases Wiki Activity

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
This commit is contained in:
Jason Gustafson 2017-06-03 06:23:53 +01:00 committed by Ismael Juma
parent eb5586102e
commit 6a5a908b1c
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
core/src/main/scala/kafka/server/DelayedFetch.scala
View File

@ -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) =>