/[Apache-SVN]
ViewVC logotype

Revision 1410055

Jump to revision: Previous Next
Author: jkreps
Date: Thu Nov 15 22:15:14 2012 UTC (11 years, 11 months ago)
Changed paths: 55
Log Message: 
KAFKA-544 Store the key given to the producer in the message. Expose this key in the consumer. Patch reviewed by Jun.

Changed paths

Path Details
Directoryincubator/kafka/branches/0.8/contrib/hadoop-consumer/src/main/java/kafka/etl/impl/DataGenerator.java modified , text changed
Directoryincubator/kafka/branches/0.8/contrib/hadoop-producer/src/main/java/kafka/bridge/hadoop/KafkaRecordWriter.java modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ConsoleConsumer.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ConsumerConnector.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ConsumerIterator.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/KafkaStream.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/consumer/ZookeeperConsumerConnector.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/producer/Producer.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/message/MessageAndMetadata.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/network/BlockingChannel.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/ConsoleProducer.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/DefaultPartitioner.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/KafkaLog4jAppender.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/KeyedMessage.scala added
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/Partitioner.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/Producer.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/ProducerData.scala deleted
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/AsyncProducerConfig.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/EventHandler.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/ProducerSendThread.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/serializer/Decoder.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/serializer/Encoder.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/KafkaMigrationTool.java modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/MirrorMaker.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/ProducerShell.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/ReplayLogProducer.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/SimpleConsumerShell.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/utils/Utils.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/other/kafka/TestEndToEndLatency.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/other/kafka/TestKafkaAppender.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/other/kafka/TestZKConsumerOffsets.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/consumer/ConsumerIteratorTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/consumer/ZookeeperConsumerConnectorTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/AutoOffsetResetTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/FetcherTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/LazyInitProducerTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/PrimitiveApiTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/ProducerConsumerTestHarness.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/javaapi/consumer/ZookeeperConsumerConnectorTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/log4j/KafkaLog4jAppenderTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/producer/AsyncProducerTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/producer/ProducerTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/LogRecoveryTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/ReplicaFetchTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/utils/TestUtils.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/utils/UtilsTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/examples/src/main/java/kafka/examples/Consumer.java modified , text changed
Directoryincubator/kafka/branches/0.8/examples/src/main/java/kafka/examples/Producer.java modified , text changed
Directoryincubator/kafka/branches/0.8/examples/src/main/java/kafka/examples/SimpleConsumerDemo.java modified , text changed
Directoryincubator/kafka/branches/0.8/perf/src/main/scala/kafka/perf/ConsumerPerformance.scala modified , text changed
Directoryincubator/kafka/branches/0.8/perf/src/main/scala/kafka/perf/ProducerPerformance.scala modified , text changed
infrastructure at apache.org
 ViewVC Help
Powered by ViewVC 1.1.26