diff --git a/core/src/main/scala/kafka/server/KafkaApis.scala b/core/src/main/scala/kafka/server/KafkaApis.scala
index 1346fb3..ddde4a3 100644
--- a/core/src/main/scala/kafka/server/KafkaApis.scala
+++ b/core/src/main/scala/kafka/server/KafkaApis.scala
@@ -206,9 +206,14 @@ class KafkaApis(val requestChannel: RequestChannel,
       sendResponseMaybeThrottle(request, _ =>
         new StopReplicaResponse(Errors.CLUSTER_AUTHORIZATION_FAILED, result.asJava))
     }
+    
+    try {
+      replicaManager.replicaFetcherManager.shutdownIdleFetcherThreads()
+    } catch {
+      case e:Exception => error("shutdownIdleFetcherThreads throw an error , error message is " + e)
+    }
 
-    replicaManager.replicaFetcherManager.shutdownIdleFetcherThreads()
-  }
+    }
 
   def handleUpdateMetadataRequest(request: RequestChannel.Request) {
     val correlationId = request.header.correlationId