/[Apache-SVN]

Revision 1367619

Jump to revision:
Author:	junrao
Date:	Tue Jul 31 15:33:29 2012 UTC (12 years, 3 months ago)
Changed paths:	54
Log Message:	revisit the become leader and become follower state change operations using V3 design; patched by Yang Ye; reviewed by Neha Narkhede and Jun Rao; kafka-343

Changed paths

Path	Details
incubator/kafka/branches/0.8/core/src/main/scala/kafka/admin/AdminUtils.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/LeaderAndISRRequest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/StopReplicaRequest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/cluster/Broker.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/cluster/Partition.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/common/BrokerNotExistException.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/common/ErrorMapping.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/TopicCount.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/log/Log.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/log/LogManager.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/network/SocketServer.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/KafkaApis.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaController.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaRequestHandler.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaServer.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaZooKeeper.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/ReplicaManager.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/RequestPurgatory.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/StateChangeCommand.scala	deleted
incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/StateChangeCommandHandler.scala	deleted
incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/ConsumerOffsetChecker.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/ExportZkOffsets.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/VerifyConsumerRebalance.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/UpdateOffsetsInZK.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/ZkQueue.scala	deleted
incubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/ZkUtils.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/consumer/ZookeeperConsumerConnectorTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/controller/ControllerBasicTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/controller/ControllerToBrokerRequestTest.scala	deleted
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/BackwardsCompatibilityTest.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/LazyInitProducerTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/PrimitiveApiTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/TopicMetadataTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/javaapi/consumer/ZookeeperConsumerConnectorTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/log/LogOffsetTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/network/SocketServerTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/producer/AsyncProducerTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/producer/ProducerTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/producer/SyncProducerTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/HighwatermarkPersistenceTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/ISRExpirationTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/LeaderElectionTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/ReplicaFetchTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/RequestPurgatoryTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/StateChangeTest.scala	deleted
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/utils/TestUtils.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/zk/ZKEphemeralTest.scala	modified , text changed

infrastructure at apache.org	ViewVC Help
Powered by ViewVC 1.1.26