From 84c49c6a098986f7da9f08dc53e6a31c13484c5b Mon Sep 17 00:00:00 2001 From: Nikhil Ramakrishnan Date: Fri, 8 Sep 2023 12:51:12 +0100 Subject: [PATCH] MINOR: Log when remote fetch execution is rejected (#14350) Log at warning level when remote fetch execution is rejected. This can be potentially useful to troubleshoot UNKNOWN_SERVER_ERROR responses for remote fetch requests. Reviewers: Luke Chen , Christo Lolov --- core/src/main/scala/kafka/server/ReplicaManager.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/core/src/main/scala/kafka/server/ReplicaManager.scala b/core/src/main/scala/kafka/server/ReplicaManager.scala index 948bd30d747..f92e3717361 100644 --- a/core/src/main/scala/kafka/server/ReplicaManager.scala +++ b/core/src/main/scala/kafka/server/ReplicaManager.scala @@ -1263,6 +1263,7 @@ class ReplicaManager(val config: KafkaConfig, } catch { case e: RejectedExecutionException => // Return the error if any in scheduling the remote fetch task + warn("Unable to fetch data from remote storage", e) return Some(createLogReadResult(e)) }