/[Apache-SVN]
ViewVC logotype

Revision 1239766

Jump to revision: Previous Next
Author: nehanarkhede
Date: Thu Feb 2 19:07:48 2012 UTC (12 years, 9 months ago)
Changed paths: 37
Log Message: 
KAFKA 256 Bug in the consumer rebalancing logic leads to the consumer not pulling data from some partitions; patched by nehanarkhede; reviewed by joelkoshy

Changed paths

Path Details
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/api/MultiFetchRequest.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/cluster/Broker.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/cluster/Cluster.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/common/ErrorMapping.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/ConsoleConsumer.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/Fetcher.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/TopicCount.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/consumer/ZookeeperTopicEventWatcher.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/javaapi/Implicits.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/javaapi/message/MessageSet.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/javaapi/producer/Producer.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/message/ByteBufferBackedInputStream.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/message/ByteBufferMessageSet.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/message/CompressionUtils.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/message/FileMessageSet.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/message/Message.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/network/SocketServer.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/network/SocketServerStats.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/producer/ConsoleProducer.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/producer/KafkaLog4jAppender.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/producer/SyncProducerConfig.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/server/KafkaServer.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/server/MultiMessageSetSend.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/tools/JmxTool.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/tools/ProducerShell.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/tools/ReplayLogProducer.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/tools/SimpleConsumerShell.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/tools/VerifyConsumerRebalance.scala added
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/utils/KafkaScheduler.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/utils/Range.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/utils/UpdateOffsetsInZK.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/utils/Utils.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/main/scala/kafka/utils/ZkUtils.scala modified , text changed
Directoryincubator/kafka/trunk/core/src/test/resources/log4j.properties modified , text changed
Directoryincubator/kafka/trunk/system_test/broker_failure/bin/run-test.sh modified , text changed
Directoryincubator/kafka/trunk/system_test/broker_failure/config/log4j.properties modified , text changed
infrastructure at apache.org
 ViewVC Help
Powered by ViewVC 1.1.26