/[Apache-SVN]
ViewVC logotype

Revision 1387270

Jump to revision: Previous Next
Author: nehanarkhede
Date: Tue Sep 18 17:21:15 2012 UTC (12 years, 1 month ago)
Changed paths: 21
Log Message: 
KAFKA-499 Refactor controller; patched by Neha Narkhede; reviewed by Jun Rao

Changed paths

Path Details
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/admin/AdminUtils.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/admin/CreateTopicCommand.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/api/LeaderAndIsrRequest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/common/StateChangeFailedException.scala added
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/controller/ added
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/controller/ControllerChannelManager.scala added
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/controller/KafkaController.scala added
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/controller/PartitionStateMachine.scala added
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/controller/ReplicaStateMachine.scala added
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaController.scala deleted
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaServer.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/server/LeaderElector.scala added
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/server/ReplicaManager.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/server/ZookeeperLeaderElector.scala added
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/VerifyConsumerRebalance.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/ShutdownableThread.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/UpdateOffsetsInZK.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/ZkUtils.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/network/RpcDataSerializationTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala modified , text changed
infrastructure at apache.org
 ViewVC Help
Powered by ViewVC 1.1.26