kafka-919; Disabling of auto commit is ignored during consumer group rebalancing; patched by Phil Hargett; reviewed by Jun Rao
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/59599cc1 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/59599cc1 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/59599cc1 Branch: refs/heads/trunk Commit: 59599cc127f32e17b07092a6c59fce742d027c47 Parents: ffd84eb Author: Phil Hargett <phil.harg...@mirror-images.com> Authored: Fri May 24 22:00:57 2013 -0700 Committer: Jun Rao <jun...@gmail.com> Committed: Fri May 24 22:00:57 2013 -0700 ---------------------------------------------------------------------- core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/59599cc1/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala b/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala index e66680b..d952187 100644 --- a/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala +++ b/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala @@ -496,6 +496,7 @@ private[kafka] class ZookeeperConsumerConnector(val config: ConsumerConfig, * by the consumer, there will be no more messages returned by this iterator until the rebalancing finishes * successfully and the fetchers restart to fetch more data chunks **/ + if (config.autoCommitEnable) commitOffsets case None => }
