/[Apache-SVN]

Revision 1310645

Jump to revision:
Author:	junrao
Date:	Sat Apr 7 00:04:51 2012 UTC (12 years ago)
Changed paths:	73
Log Message:	Separate out Kafka mirroring into a stand-alone app; patched by Joel Koshy; reviewed by Jun Rao and Neha Narkhede; KAFKA-249

Changed paths

Path	Details
incubator/kafka/trunk/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLContext.java	modified , text changed
incubator/kafka/trunk/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLInputFormat.java	modified , text changed
incubator/kafka/trunk/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLJob.java	modified , text changed
incubator/kafka/trunk/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLKey.java	modified , text changed
incubator/kafka/trunk/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLUtils.java	modified , text changed
incubator/kafka/trunk/contrib/hadoop-consumer/src/main/java/kafka/etl/impl/DataGenerator.java	modified , text changed
incubator/kafka/trunk/contrib/hadoop-producer/src/main/java/kafka/bridge/examples/TextPublisher.java	modified , text changed
incubator/kafka/trunk/contrib/hadoop-producer/src/main/java/kafka/bridge/hadoop/KafkaOutputFormat.java	modified , text changed
incubator/kafka/trunk/contrib/hadoop-producer/src/main/java/kafka/bridge/hadoop/KafkaRecordWriter.java	modified , text changed
incubator/kafka/trunk/contrib/hadoop-producer/src/main/java/kafka/bridge/pig/AvroKafkaStorage.java	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/Kafka.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsoleConsumer.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsumerConfig.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsumerConnector.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsumerIterator.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/consumer/Fetcher.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/consumer/KafkaMessageStream.scala	deleted
incubator/kafka/trunk/core/src/main/scala/kafka/consumer/KafkaStream.scala	added
incubator/kafka/trunk/core/src/main/scala/kafka/consumer/TopicCount.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/consumer/TopicFilter.scala	added
incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ZookeeperTopicEventWatcher.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/javaapi/consumer/ZookeeperConsumerConnector.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/javaapi/message/MessageSet.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/javaapi/producer/async/CallbackHandler.java	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/javaapi/producer/async/EventHandler.java	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/message/ByteBufferMessageSet.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/message/MessageAndMetadata.scala	added
incubator/kafka/trunk/core/src/main/scala/kafka/message/MessageAndOffset.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/producer/KafkaLog4jAppender.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/producer/Producer.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/server/KafkaServerStartable.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/tools/ConsumerShell.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/tools/MirrorMaker.scala	added
incubator/kafka/trunk/core/src/main/scala/kafka/tools/ReplayLogProducer.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/utils/Logging.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/utils/Utils.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/utils/ZkUtils.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/other/kafka/TestZKConsumerOffsets.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/unit/kafka/consumer/TopicCountTest.scala	deleted
incubator/kafka/trunk/core/src/test/scala/unit/kafka/consumer/TopicFilterTest.scala	added
incubator/kafka/trunk/core/src/test/scala/unit/kafka/consumer/ZookeeperConsumerConnectorTest.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/unit/kafka/integration/FetcherTest.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/unit/kafka/javaapi/consumer/ZookeeperConsumerConnectorTest.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/unit/kafka/utils/UtilsTest.scala	modified , text changed
incubator/kafka/trunk/examples/src/main/java/kafka/examples/Consumer.java	modified , text changed
incubator/kafka/trunk/examples/src/main/java/kafka/examples/ExampleUtils.java	modified , text changed
incubator/kafka/trunk/examples/src/main/java/kafka/examples/Producer.java	modified , text changed
incubator/kafka/trunk/examples/src/main/java/kafka/examples/SimpleConsumerDemo.java	modified , text changed
incubator/kafka/trunk/perf/src/main/scala/kafka/perf/ConsumerPerformance.scala	modified , text changed
incubator/kafka/trunk/perf/src/main/scala/kafka/perf/PerfConfig.scala	modified , text changed
incubator/kafka/trunk/perf/src/main/scala/kafka/perf/SimpleConsumerPerformance.scala	modified , text changed
incubator/kafka/trunk/system_test/embedded_consumer/	deleted
incubator/kafka/trunk/system_test/mirror_maker/	added
incubator/kafka/trunk/system_test/mirror_maker/README	added
incubator/kafka/trunk/system_test/mirror_maker/bin/	added
incubator/kafka/trunk/system_test/mirror_maker/bin/expected.out	added
incubator/kafka/trunk/system_test/mirror_maker/bin/run-test.sh	added
incubator/kafka/trunk/system_test/mirror_maker/config/	added
incubator/kafka/trunk/system_test/mirror_maker/config/blacklisttest.consumer.properties	added
incubator/kafka/trunk/system_test/mirror_maker/config/mirror_producer.properties	added
incubator/kafka/trunk/system_test/mirror_maker/config/server_source_1_1.properties	added
incubator/kafka/trunk/system_test/mirror_maker/config/server_source_1_2.properties	added
incubator/kafka/trunk/system_test/mirror_maker/config/server_source_2_1.properties	added
incubator/kafka/trunk/system_test/mirror_maker/config/server_source_2_2.properties	added
incubator/kafka/trunk/system_test/mirror_maker/config/server_target_1_1.properties	added
incubator/kafka/trunk/system_test/mirror_maker/config/server_target_1_2.properties	added
incubator/kafka/trunk/system_test/mirror_maker/config/whitelisttest_1.consumer.properties	added
incubator/kafka/trunk/system_test/mirror_maker/config/whitelisttest_2.consumer.properties	added
incubator/kafka/trunk/system_test/mirror_maker/config/zookeeper_source_1.properties	added
incubator/kafka/trunk/system_test/mirror_maker/config/zookeeper_source_2.properties	added
incubator/kafka/trunk/system_test/mirror_maker/config/zookeeper_target.properties	added

infrastructure at apache.org	ViewVC Help
Powered by ViewVC 1.1.26