diff --git a/core/src/main/scala/kafka/server/ReplicaManager.scala b/core/src/main/scala/kafka/server/ReplicaManager.scala index 15d9c6a2a0..510f707578 100644 --- a/core/src/main/scala/kafka/server/ReplicaManager.scala +++ b/core/src/main/scala/kafka/server/ReplicaManager.scala @@ -1105,7 +1105,7 @@ class ReplicaManager(val config: KafkaConfig, } warn(s"Returning emtpy fetch response for fetch request ${fetchInfos} since the " + s"wait time ${waitedTimeMs} exceed ${params.maxWaitMs} ms.") - responseEmpty(new TimeoutException(s"wait time ${waitedTimeMs}ms exceed ${params.maxWaitMs}ms.")) + responseEmpty(null) false } }