/[Apache-SVN]

Revision 1241754

Jump to revision:
Author:	junrao
Date:	Wed Feb 8 02:59:54 2012 UTC (12 years, 9 months ago)
Changed paths:	32
Log Message:	refactor the async producer; patched by Jun Rao; reviewed by Neha Narkhede; KAFKA-253

Changed paths

Path	Details
incubator/kafka/branches/0.8/core/src/main/scala/kafka/common/FailedToSendMessageException.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/Implicits.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/producer/Producer.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/producer/ProducerData.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/javaapi/producer/async/	deleted
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/BrokerPartitionInfo.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/ConfigBrokerPartitionInfo.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/Producer.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/ProducerClosedException.scala	added
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/ProducerConfig.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/ProducerData.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/ProducerPool.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/AsyncProducer.scala	deleted
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/AsyncProducerConfig.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/AsyncProducerInterruptedException.scala	deleted
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/AsyncProducerStats.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/AsyncProducerStatsMBean.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/CallbackHandler.scala	deleted
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/producer/async/EventHandler.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/ProducerSendThread.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/main/scala/kafka/producer/async/QueueClosedException.scala	deleted
incubator/kafka/branches/0.8/core/src/main/scala/kafka/tools/ReplayLogProducer.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/consumer/ZookeeperConsumerConnectorTest.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/consumer/ZookeeperConsumerConnectorTest.scala	modified , text changed
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/javaapi/producer/	deleted
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/ProducerMethodsTest.scala	deleted
incubator/kafka/branches/0.8/core/src/test/scala/unit/kafka/producer/ProducerTest.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