/[Apache-SVN]

Revision 1344964

Jump to revision:
Author:	nehanarkhede
Date:	Fri Jun 1 01:53:19 2012 UTC (12 years, 5 months ago)
Changed paths:	45
Log Message:	KAFKA-46: Message replication feature without failures; patched by Neha Narkhede; reviewed by Jun Rao, Jay Kreps, Prashanth Menon

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/api/FetchRequest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/FetchResponse.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/NotLeaderForPartitionException.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/common/UnknownTopicException.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/log/Log.scala	replaced
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/log/LogStats.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/log/SegmentList.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/message/FileMessageSet.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/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/	modified , props 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/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/ReplicaFetcherThread.scala	added
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/utils/KafkaScheduler.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/resources/log4j.properties	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/other/kafka/inmemory/	added
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/consumer/TopicCountTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/AutoOffsetResetTest.scala	modified , text changed
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/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/log/LogTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/log/SegmentListTest.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/ISRExpirationTest.scala	added
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/ReplicaFetchTest.scala	added
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

infrastructure at apache.org	ViewVC Help
Powered by ViewVC 1.1.26