 incubator/kafka/branches/0.8/
|
modified
, props changed
|
 incubator/kafka/branches/0.8/clients/cpp/src/encoder.hpp
|
modified
, text changed
|
| incubator/kafka/branches/0.8/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLContext.java
|
modified
, text changed
|
| incubator/kafka/branches/0.8/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLInputFormat.java
|
modified
, text changed
|
| incubator/kafka/branches/0.8/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLJob.java
|
modified
, text changed
|
| incubator/kafka/branches/0.8/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLKey.java
|
modified
, text changed
|
| incubator/kafka/branches/0.8/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLUtils.java
|
modified
, text changed
|
| incubator/kafka/branches/0.8/contrib/hadoop-consumer/src/main/java/kafka/etl/impl/DataGenerator.java
|
modified
, text changed
|
| incubator/kafka/branches/0.8/contrib/hadoop-producer/README.md
|
modified
, text changed
|
| incubator/kafka/branches/0.8/contrib/hadoop-producer/src/main/java/kafka/bridge/examples/TextPublisher.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/contrib/hadoop-producer/src/main/java/kafka/bridge/hadoop/KafkaRecordWriter.java
|
modified
, text changed
|
| incubator/kafka/branches/0.8/contrib/hadoop-producer/src/main/java/kafka/bridge/pig/AvroKafkaStorage.java
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/Kafka.scala
|
modified
, text changed
|
| 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/ConsumerConfig.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ConsumerConnector.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/Fetcher.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/KafkaMessageStream.scala
|
deleted
|
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/KafkaStream.scala
(Copied from incubator/kafka/trunk/core/src/main/scala/kafka/consumer/KafkaStream.scala, r1343118)
|
added
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/TopicCount.scala
|
modified
, text changed
|
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/TopicFilter.scala
(Copied from incubator/kafka/trunk/core/src/main/scala/kafka/consumer/TopicFilter.scala, r1343118)
|
added
|
| 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/ZookeeperTopicEventWatcher.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/consumer/ZookeeperConsumerConnector.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/message/MessageSet.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/message/ByteBufferMessageSet.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/message/CompressionUtils.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/message/InvalidMessageException.scala
|
modified
, text changed
|
incubator/kafka/branches/0.8/core/src/main/scala/kafka/message/MessageAndMetadata.scala
(Copied from incubator/kafka/trunk/core/src/main/scala/kafka/message/MessageAndMetadata.scala, r1343118)
|
added
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/message/MessageAndOffset.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/ConsoleProducer.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/KafkaLog4jAppender.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/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/ProducerSendThread.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/KafkaRequestHandler.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaServerStartable.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/ConsumerShell.scala
|
modified
, text changed
|
incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/ExportZkOffsets.scala
(Copied from incubator/kafka/trunk/core/src/main/scala/kafka/tools/ExportZkOffsets.scala, r1343118)
|
added
|
incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/ImportZkOffsets.scala
(Copied from incubator/kafka/trunk/core/src/main/scala/kafka/tools/ImportZkOffsets.scala, r1343118)
|
added
|
incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/MirrorMaker.scala
(Copied from incubator/kafka/trunk/core/src/main/scala/kafka/tools/MirrorMaker.scala, r1343118)
|
added
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/ReplayLogProducer.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/VerifyConsumerRebalance.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/Logging.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/other/kafka/TestEndToEndLatency.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/other/kafka/TestZKConsumerOffsets.scala
|
modified
, text changed
|
| 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/consumer/TopicFilterTest.scala
(Copied from incubator/kafka/trunk/core/src/test/scala/unit/kafka/consumer/TopicFilterTest.scala, r1343118)
|
added
|
| 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/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/javaapi/consumer/ZookeeperConsumerConnectorTest.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/log/LogManagerTest.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/log4j/KafkaLog4jAppenderTest.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/message/ByteBufferMessageSetTest.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/network/SocketServerTest.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/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/examples/src/main/java/kafka/examples/Consumer.java
|
modified
, text changed
|
| incubator/kafka/branches/0.8/examples/src/main/java/kafka/examples/ExampleUtils.java
|
modified
, text changed
|
| incubator/kafka/branches/0.8/examples/src/main/java/kafka/examples/Producer.java
|
modified
, text changed
|
| incubator/kafka/branches/0.8/examples/src/main/java/kafka/examples/SimpleConsumerDemo.java
|
modified
, text changed
|
| incubator/kafka/branches/0.8/perf/src/main/scala/kafka/perf/ConsumerPerformance.scala
|
modified
, text changed
|
| incubator/kafka/branches/0.8/perf/src/main/scala/kafka/perf/PerfConfig.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/broker_failure/bin/run-test.sh
|
modified
, text changed
|
| incubator/kafka/branches/0.8/system_test/broker_failure/config/log4j.properties
|
modified
, text changed
|
| incubator/kafka/branches/0.8/system_test/broker_failure/config/mirror_producer1.properties
|
modified
, text changed
|
| incubator/kafka/branches/0.8/system_test/broker_failure/config/mirror_producer2.properties
|
modified
, text changed
|
| incubator/kafka/branches/0.8/system_test/broker_failure/config/mirror_producer3.properties
|
modified
, text changed
|
| incubator/kafka/branches/0.8/system_test/broker_failure/config/server_source1.properties
|
modified
, text changed
|
| incubator/kafka/branches/0.8/system_test/broker_failure/config/server_source2.properties
|
modified
, text changed
|
| incubator/kafka/branches/0.8/system_test/broker_failure/config/server_source3.properties
|
modified
, text changed
|
| incubator/kafka/branches/0.8/system_test/broker_failure/config/server_source4.properties
|
modified
, text changed
|
| incubator/kafka/branches/0.8/system_test/broker_failure/config/server_target1.properties
|
modified
, text changed
|
| incubator/kafka/branches/0.8/system_test/broker_failure/config/server_target2.properties
|
modified
, text changed
|
| incubator/kafka/branches/0.8/system_test/broker_failure/config/server_target3.properties
|
modified
, text changed
|
| incubator/kafka/branches/0.8/system_test/broker_failure/config/whitelisttest.consumer.properties
|
modified
, text changed
|
| incubator/kafka/branches/0.8/system_test/embedded_consumer/
|
deleted
|
incubator/kafka/branches/0.8/system_test/mirror_maker/
(Copied from incubator/kafka/trunk/system_test/mirror_maker, r1343118)
|
added
|
incubator/kafka/branches/0.8/system_test/mirror_maker/README
(Copied from incubator/kafka/trunk/system_test/mirror_maker/README, r1343118)
|
replaced
|
incubator/kafka/branches/0.8/system_test/mirror_maker/bin/
(Copied from incubator/kafka/trunk/system_test/mirror_maker/bin, r1343118)
|
replaced
|
incubator/kafka/branches/0.8/system_test/mirror_maker/bin/expected.out
(Copied from incubator/kafka/trunk/system_test/mirror_maker/bin/expected.out, r1343118)
|
replaced
|
incubator/kafka/branches/0.8/system_test/mirror_maker/bin/run-test.sh
(Copied from incubator/kafka/trunk/system_test/mirror_maker/bin/run-test.sh, r1343118)
|
replaced
|
incubator/kafka/branches/0.8/system_test/mirror_maker/config/
(Copied from incubator/kafka/trunk/system_test/mirror_maker/config, r1343118)
|
replaced
|
incubator/kafka/branches/0.8/system_test/mirror_maker/config/blacklisttest.consumer.properties
(Copied from incubator/kafka/trunk/system_test/mirror_maker/config/blacklisttest.consumer.properties, r1343118)
|
replaced
|
incubator/kafka/branches/0.8/system_test/mirror_maker/config/mirror_producer.properties
(Copied from incubator/kafka/trunk/system_test/mirror_maker/config/mirror_producer.properties, r1343118)
|
replaced
|
incubator/kafka/branches/0.8/system_test/mirror_maker/config/server_source_1_1.properties
(Copied from incubator/kafka/trunk/system_test/mirror_maker/config/server_source_1_1.properties, r1343118)
|
replaced
|
| [...] |
