/[Apache-SVN]

Revision 1396713

Jump to revision:
Author:	nehanarkhede
Date:	Wed Oct 10 18:03:07 2012 UTC (12 years, 1 month ago)
Changed paths:	52
Log Message:	KAFKA-42 Cluster expansion feature; patched by Neha Narkhede; reviewed by Jun Rao

Changed paths

Path	Details
incubator/kafka/branches/0.8/bin/kafka-check-reassignment-status.sh	added
incubator/kafka/branches/0.8/bin/kafka-reassign-partitions.sh	added
incubator/kafka/branches/0.8/config/server.properties	modified , text changed
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/admin/CheckReassignmentStatus.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala	added
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/Partition.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/common/AdminCommandFailedException.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/common/PartitionOfflineException.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/common/StateChangeFailedException.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/controller/ControllerChannelManager.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/controller/KafkaController.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/controller/PartitionLeaderSelector.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/controller/PartitionStateMachine.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/controller/ReplicaStateMachine.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/log/FileMessageSet.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/LogSegment.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/log/OffsetIndex.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/metrics/KafkaCSVMetricsReporter.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/network/RequestChannel.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/ProducerPool.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/ProducerSendThread.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/KafkaApis.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/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/tools/ConsumerOffsetChecker.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/DumpLogSegments.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/Utils.scala	modified , text changed
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/admin/AdminTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/api/RequestResponseSerializationTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/log/FileMessageSetTest.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/log/LogSegmentTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/log/LogTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/log/OffsetIndexTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/message/BaseMessageSetTestCases.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/message/MessageCompressionTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/metrics/KafkaTimerTest.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/RequestPurgatoryTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/utils/TestUtils.scala	modified , text changed
incubator/kafka/branches/0.8/project/build/KafkaProject.scala	modified , text changed
incubator/kafka/branches/0.8/system_test/testcase_to_run.json	modified , text changed

infrastructure at apache.org	ViewVC Help
Powered by ViewVC 1.1.26