/[Apache-SVN]

Revision 1365199

Jump to revision:
Author:	nehanarkhede
Date:	Tue Jul 24 18:13:01 2012 UTC (11 years, 9 months ago)
Changed paths:	71
Log Message:	KAFKA-350 Enable message replication in the presence of failures; patched by Neha Narkhede; reviewed by Jun Rao and Jay Kreps

Changed paths

Path	Details
incubator/kafka/branches/0.8/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLRecordReader.java	modified , text changed
incubator/kafka/branches/0.8/contrib/hadoop-consumer/src/main/java/kafka/etl/Props.java	modified , text changed
incubator/kafka/branches/0.8/contrib/hadoop-producer/src/main/java/kafka/bridge/hadoop/KafkaOutputFormat.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/FetchRequest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/TopicMetaDataResponse.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/TopicMetadata.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/TopicMetadataRequest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/cluster/Broker.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/KafkaException.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/common/LeaderNotAvailableException.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/common/NoLeaderForPartitionException.scala	deleted
incubator/kafka/branches/0.8/core/src/main/scala/kafka/common/ReplicaNotAvailableException.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ConsoleConsumer.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ConsumerIterator.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/consumer/storage/OracleOffsetStorage.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/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/BoundedByteBufferSend.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/network/Transmission.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/Producer.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/ProducerConfig.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/ProducerData.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/SyncProducer.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/SyncProducerConfig.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/KafkaConfig.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaController.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/main/scala/kafka/server/StateChangeCommand.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/IteratorTemplate.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/UpdateOffsetsInZK.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/integration/KafkaServerTestHarness.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/LazyInitProducerTest.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/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/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/ISRExpirationTest.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/LogRecoveryTest.scala	added
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/ServerShutdownTest.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/core/src/test/scala/unit/kafka/utils/UtilsTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/zk/EmbeddedZookeeper.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/zk/ZooKeeperTestHarness.scala	modified , text changed
incubator/kafka/branches/0.8/perf/src/main/scala/kafka/perf/ProducerPerformance.scala	modified , text changed
incubator/kafka/branches/0.8/system_test/common/util.sh	modified , text changed
incubator/kafka/branches/0.8/system_test/single_host_multi_brokers/bin/run-test.sh	modified , text changed
incubator/kafka/branches/0.8/system_test/single_host_multi_brokers/config/log4j.properties	modified , text changed
incubator/kafka/branches/0.8/system_test/single_host_multi_brokers/config/server.properties	modified , text changed

infrastructure at apache.org	ViewVC Help
Powered by ViewVC 1.1.26