/[Apache-SVN]

Revision 1228504

Jump to revision:
Author:	nehanarkhede
Date:	Sat Jan 7 00:01:25 2012 UTC (12 years, 10 months ago)
Changed paths:	12
Log Message:	KAFKA-228 Reduce duplicate messages served by the kafka consumer for uncompressed topics; patched by nehanarkhede; reviewed by junrao

Changed paths

Path	Details
incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsumerIterator.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/consumer/Fetcher.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/consumer/FetcherRunnable.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/consumer/KafkaMessageStream.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/consumer/PartitionTopicInfo.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/consumer/SimpleConsumer.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/consumer/storage/OffsetStorage.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/producer/async/DefaultEventHandler.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/server/KafkaRequestHandlers.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/unit/kafka/integration/FetcherTest.scala	modified , text changed
incubator/kafka/trunk/system_test/broker_failure/bin/run-test.sh	modified , text changed

infrastructure at apache.org	ViewVC Help
Powered by ViewVC 1.1.26