perf(DelayedFetch): only try to fast read on complete a delayed fetch (#2013)

Chillax-0v0 · web-flow · commit 26a4e1d15174 · 2024-09-11T11:19:15.000+08:00
Signed-off-by: Ning Yu &lt;ningyu@automq.com&gt;
diff --git a/core/src/main/scala/kafka/server/streamaspect/ElasticReplicaManager.scala b/core/src/main/scala/kafka/server/streamaspect/ElasticReplicaManager.scala
@@ -515,6 +515,9 @@ class ElasticReplicaManager(
           fetchPartitionStatus = fetchPartitionStatus,
           replicaManager = this,
           quota = quota,
+          // Always use the fast fetch limiter in delayed fetch operations, as when a delayed fetch
+          // operation is completed, it only try to read in the fast path.
+          limiter = fastFetchLimiter,
           responseCallback = responseCallback
         )
 

Original file line number	Diff line number	Diff line change
`@@ -515,6 +515,9 @@ class ElasticReplicaManager(`
`515`	`515`	`fetchPartitionStatus = fetchPartitionStatus,`
`516`	`516`	`replicaManager = this,`
`517`	`517`	`quota = quota,`
	`518`	`+ // Always use the fast fetch limiter in delayed fetch operations, as when a delayed fetch`
	`519`	`+ // operation is completed, it only try to read in the fast path.`
	`520`	`+ limiter = fastFetchLimiter,`
`518`	`521`	`responseCallback = responseCallback`
`519`	`522`	`)`
`520`	`523`