[ https://issues.apache.org/jira/browse/KAFKA-2158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jiasheng Wang updated KAFKA-2158: --------------------------------- Status: Open (was: Patch Available) > 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)