/[Apache-SVN]

Revision 1360261

Jump to revision:
Author:	junrao
Date:	Wed Jul 11 16:16:26 2012 UTC (11 years, 9 months ago)
Changed paths:	14
Log Message:	ZookeeperConsumerConnector needs to connect to new leader after leadership change; patched by Jun Rao; reviewed by Joel Koshy; KAFKA-362

Changed paths

Path	Details
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ConsumerConfig.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ConsumerFetcherThread.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/Fetcher.scala	deleted
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/FetcherRunnable.scala	deleted
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/PartitionTopicInfo.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/AbstractFetcherManager.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/AbstractFetcherThread.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaConfig.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/ReplicaFetcherManager.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/ReplicaFetcherThread.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/FetcherTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/LogCorruptionTest.scala	modified , text changed

infrastructure at apache.org	ViewVC Help
Powered by ViewVC 1.1.26