/[Apache-SVN]
ViewVC logotype

Revision 1402395


Jump to revision: Previous Next
Author: jjkoshy
Date: Fri Oct 26 05:23:55 2012 UTC (12 years ago)
Changed paths: 15
Log Message:
Implement clean shutdown in replication; patched by Joel Koshy; reviewed by Jun Rao and Neha Narkhede; KAFKA-340

Changed paths

Path Details
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/admin/ShutdownBroker.scala added
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/api/StopReplicaRequest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/common/TopicAndPartition.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/controller/ControllerChannelManager.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/controller/KafkaController.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/controller/PartitionLeaderSelector.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/controller/PartitionStateMachine.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/controller/ReplicaStateMachine.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/server/AbstractFetcherManager.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaApis.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/server/ReplicaFetcherManager.scala modified , text changed
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/utils/ZkUtils.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/admin/AdminTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/api/RequestResponseSerializationTest.scala modified , text changed

infrastructure at apache.org
ViewVC Help
Powered by ViewVC 1.1.26