/[Apache-SVN]

Revision 1242552

Jump to revision:
Author:	nehanarkhede
Date:	Thu Feb 9 22:04:32 2012 UTC (12 years, 9 months ago)
Changed paths:	23
Log Message:	KAFKA-262 Bug in the consumer rebalancing logic causes one consumer to release partitions that it does not own; patched by Neha Narkhede; reviewed by Jun Rao

Changed paths

Path	Details
incubator/kafka/trunk/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/message/CompressionUtils.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/producer/KafkaLog4jAppender.scala	modified , text changed
incubator/kafka/trunk/core/src/main/scala/kafka/tools/VerifyConsumerRebalance.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/other/kafka/TestKafkaAppender.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/other/kafka/TestLinearWriteSpeed.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/other/kafka/TestLogPerformance.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/unit/kafka/integration/BackwardsCompatibilityTest.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/unit/kafka/javaapi/message/BaseMessageSetTestCases.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/unit/kafka/javaapi/message/ByteBufferMessageSetTest.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/unit/kafka/javaapi/producer/ProducerTest.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/unit/kafka/javaapi/producer/SyncProducerTest.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/unit/kafka/log/LogTest.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/unit/kafka/log4j/KafkaLog4jAppenderTest.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/unit/kafka/message/BaseMessageSetTestCases.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/unit/kafka/message/FileMessageSetTest.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/unit/kafka/message/MessageTest.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/unit/kafka/network/SocketServerTest.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/unit/kafka/producer/AsyncProducerTest.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/unit/kafka/producer/ProducerTest.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/unit/kafka/producer/SyncProducerTest.scala	modified , text changed
incubator/kafka/trunk/core/src/test/scala/unit/kafka/server/ServerShutdownTest.scala	modified , text changed

infrastructure at apache.org	ViewVC Help
Powered by ViewVC 1.1.26