From 0a0f9f09ec3295d274e05de3ea1de9049f59dc43 Mon Sep 17 00:00:00 2001
From: Alexey Ozeritsky <aozeritsky@yandex-team.ru>
Date: Tue, 11 Oct 2016 14:21:16 +0300
Subject: [PATCH] KAFKA-4319; AbstractFetcherManager: shutdown speedup

---
 core/src/main/scala/kafka/server/AbstractFetcherManager.scala | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/core/src/main/scala/kafka/server/AbstractFetcherManager.scala b/core/src/main/scala/kafka/server/AbstractFetcherManager.scala
index 8f6b84fb1144..d87a8cfc6c28 100755
--- a/core/src/main/scala/kafka/server/AbstractFetcherManager.scala
+++ b/core/src/main/scala/kafka/server/AbstractFetcherManager.scala
@@ -118,6 +118,10 @@ abstract class AbstractFetcherManager(protected val name: String, clientId: Stri
 
   def closeAllFetchers() {
     mapLock synchronized {
+      for ( (_, fetcher) <- fetcherThreadMap) {
+        fetcher.initiateShutdown()
+      }
+
       for ( (_, fetcher) <- fetcherThreadMap) {
         fetcher.shutdown()
       }