Jiasheng Wang created KAFKA-2158:
------------------------------------
Summary: Close all fetchers in AbstractFetcherManager without
blocking
Key: KAFKA-2158
URL: https://issues.apache.org/jira/browse/KAFKA-2158
Project: Kafka
Issue Type: Improvement
Components: core
Reporter: Jiasheng Wang
def closeAllFetchers() {
mapLock synchronized {
for ( (_, fetcher) <- fetcherThreadMap) {
fetcher.shutdown()
}
fetcherThreadMap.clear()
}
}
It is time consuming for closeAllFetchers() in AbstractFetcherManager.scala
because each time a fetcher calls shutdown method it will block until
awaitShutdown() returns. As a result it will slow down the restart of kafka
service.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
