DelayedFetch should propagate isolation level to log read
Tests will be added in a subsequent commit.
Author: Jason Gustafson
Reviewers: Ismael Juma
Closes from hachikuji/KAFKA-5355
@@ -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) =>
