/
[Apache-SVN]
Revision 1375670
Jump to revision:
Author:
junrao
Date:
Tue Aug 21 17:17:29 2012 UTC
(12 years, 2 months ago)
Changed paths:
31
Log Message:
refactor ReplicaManager; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-351
Changed paths
Path
Details
incubator/kafka/branches/0.8/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLContext.java
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/ListTopicCommand.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/LeaderAndISRResponse.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/cluster/Replica.scala
modified
,
text changed
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/common/InvalidPartitionException.scala
deleted
incubator/kafka/branches/0.8/core/src/main/scala/kafka/common/UnknownTopicOrPartitionException.scala
added
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/producer/BrokerPartitionInfo.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/DefaultEventHandler.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/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/ReplicaFetcherThread.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/test/scala/unit/kafka/admin/AdminTest.scala
modified
,
text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/consumer/TopicCountTest.scala
deleted
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/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/log/LogOffsetTest.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/LogRecoveryTest.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/system_test/single_host_multi_brokers/bin/run-test.sh
modified
,
text changed
infrastructure at apache.org
ViewVC Help
Powered by
ViewVC 1.1.26