/[Apache-SVN]

Revision 1386806

Jump to revision:
Author:	jjkoshy
Date:	Mon Sep 17 20:15:59 2012 UTC (12 years, 2 months ago)
Changed paths:	32
Log Message:	KAFKA-391 Refactor fetch/producer requests to use maps instead of several arrays; patched by Joel Koshy; reviewed by Jun Rao.

Changed paths

Path	Details
incubator/kafka/branches/0.8/contrib/hadoop-consumer/src/main/java/kafka/etl/impl/DataGenerator.java	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/FetchRequest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/FetchResponse.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/ProducerRequest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/ProducerResponse.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/RequestOrResponse.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/common/ErrorMapping.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/common/FetchRequestFormatException.scala	deleted
incubator/kafka/branches/0.8/core/src/main/scala/kafka/common/TopicAndPartition.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ConsumerFetcherThread.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/FetchRequest.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/FetchResponse.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/ProducerRequest.scala	deleted
incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/consumer/SimpleConsumer.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/producer/SyncProducer.scala	deleted
incubator/kafka/branches/0.8/core/src/main/scala/kafka/network/RequestChannel.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/async/DefaultEventHandler.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/AbstractFetcherThread.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/ReplicaFetcherManager.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/ReplicaFetcherThread.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/test/scala/unit/kafka/integration/LazyInitProducerTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/PrimitiveApiTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/javaapi/integration/	deleted
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/network/RpcDataSerializationTest.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/AsyncProducerTest.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/utils/TestUtils.scala	modified , text changed

infrastructure at apache.org	ViewVC Help
Powered by ViewVC 1.1.26