/[Apache-SVN]
ViewVC logotype

Revision 1176671


Jump to revision: Previous Next
Author: junrao
Date: Wed Sep 28 00:42:30 2011 UTC (13 years ago)
Changed paths: 14
Log Message:
Consumer needs a pluggable decoder; patched by Joel Koshy; reviewed by Jun Rao; KAFKA-3

Changed paths

Path Details
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsoleConsumer.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsumerConnector.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsumerIterator.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/KafkaMessageStream.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/javaapi/consumer/ConsumerConnector.java modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/javaapi/consumer/ZookeeperConsumerConnector.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/tools/ConsumerShell.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/tools/ReplayLogProducer.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/test/scala/other/kafka/TestZKConsumerOffsets.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/test/scala/unit/kafka/consumer/ZookeeperConsumerConnectorTest.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/test/scala/unit/kafka/javaapi/consumer/ZookeeperConsumerConnectorTest.scala modified , text changed
Directoryincubator/kafka/trunk/examples/src/main/java/kafka/examples/Consumer.java modified , text changed
Directoryincubator/kafka/trunk/project/build/KafkaProject.scala modified , text changed

infrastructure at apache.org
ViewVC Help
Powered by ViewVC 1.1.26