kafka-880; NoLeaderPartitionSet should be cleared before leader finder thread is started up; patched by Jun Rao; reviewed by Neha Narkhede
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/6e640e35 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/6e640e35 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/6e640e35 Branch: refs/heads/trunk Commit: 6e640e355632d97e322e462c2bbc379c05d407a4 Parents: 2d74031 Author: Jun Rao <[email protected]> Authored: Thu Apr 25 19:03:21 2013 -0700 Committer: Jun Rao <[email protected]> Committed: Thu Apr 25 19:03:21 2013 -0700 ---------------------------------------------------------------------- core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/6e640e35/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala b/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala index d1373c9..c6250dc 100644 --- a/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala +++ b/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala @@ -129,6 +129,10 @@ class ConsumerFetcherManager(private val consumerIdString: String, info("Stopping all fetchers") closeAllFetchers() + // no need to hold the lock for the following since leaderFindThread and all fetchers have been stopped + partitionMap = null + noLeaderPartitionSet.clear() + info("All connections stopped") }
