/[Apache-SVN]

Revision 1346697

Jump to revision:
Author:	junrao
Date:	Wed Jun 6 01:28:46 2012 UTC (12 years, 5 months ago)
Changed paths:	32
Log Message:	Add admin RPC requests; clean up Response objects; patched by Yang Ye; reviewed by Jun Rao; KAFKA-349; KAFKA-336

Changed paths

Path	Details
incubator/kafka/branches/0.8/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLContext.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/LeaderAndISRRequest.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/LeaderAndISRResponse.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/OffsetRequest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/OffsetResponse.scala	added
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/RequestKeys.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/RequestOrResponse.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/StopReplicaRequest.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/StopReplicaResponse.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/TopicMetaDataResponse.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/api/TopicMetadataRequest.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/consumer/SimpleConsumer.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/ProducerRequest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/message/ByteBufferMessageSet.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/network/BlockingChannel.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/network/BoundedByteBufferSend.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/network/Request.scala	deleted
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/server/KafkaApis.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/server/MessageSetSend.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/controller/	added
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/controller/ControllerToBrokerRequestTest.scala	added
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/integration/TopicMetadataTest.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/producer/AsyncProducerTest.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