/[Apache-SVN]
ViewVC logotype

Revision 1243407

Jump to revision: Previous Next
Author: junrao
Date: Mon Feb 13 03:58:37 2012 UTC (12 years, 8 months ago)
Changed paths: 37
Log Message: 
new consumer request format; patched by Prashanth Menon; reviewed by Jun Rao and Jay Kreps; KAFKA-240

Changed paths

Path Details
Directoryincubator/kafka/branches/0.8/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLContext.java modified , text changed
Directoryincubator/kafka/branches/0.8/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLRequest.java modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/api/FetchRequest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/api/FetchResponse.scala added
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/api/MultiFetchRequest.scala deleted
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/api/MultiFetchResponse.scala deleted
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/api/RequestKeys.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ConsumerConfig.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/FetcherRunnable.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/SimpleConsumer.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/TopicCount.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/FetchResponse.scala added
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/Implicits.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/MultiFetchResponse.scala deleted
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/consumer/SimpleConsumer.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/network/BoundedByteBufferReceive.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/network/RequestChannel.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/network/SocketServerStats.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/network/Transmission.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaApis.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/main/scala/kafka/server/KafkaRequestHandler.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/test/scala/unit/kafka/integration/BackwardsCompatibilityTest.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/LogCorruptionTest.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/javaapi/integration/PrimitiveApiTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/log/LogOffsetTest.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/ProducerTest.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/zk/ZKLoadBalanceTest.scala modified , text changed
Directoryincubator/kafka/branches/0.8/examples/src/main/java/kafka/examples/KafkaProperties.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/SimpleConsumerPerformance.scala modified , text changed
infrastructure at apache.org
 ViewVC Help
Powered by ViewVC 1.1.26