mirror of https://github.com/apache/kafka.git
Merge 5b4067eba4
into 4a5aa37169
This commit is contained in:
commit
a325e00572
|
@ -1649,7 +1649,7 @@ class ReplicaManager(val config: KafkaConfig,
|
|||
remoteFetchPartitionStatus, params, logReadResults, this, responseCallback)
|
||||
|
||||
// create a list of (topic, partition) pairs to use as keys for this delayed fetch operation
|
||||
val delayedFetchKeys = remoteFetchPartitionStatus.map { case (tp, _) => new TopicPartitionOperationKey(tp) }.toList
|
||||
val delayedFetchKeys = remoteFetchTasks.asScala.map { case (tp, _) => new TopicPartitionOperationKey(tp) }.toList
|
||||
delayedRemoteFetchPurgatory.tryCompleteElseWatch(remoteFetch, delayedFetchKeys.asJava)
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue