kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject svn commit: r1396678 - /incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala
Date Wed, 10 Oct 2012 16:33:43 GMT
Author: junrao
Date: Wed Oct 10 16:33:42 2012
New Revision: 1396678

URL: http://svn.apache.org/viewvc?rev=1396678&view=rev
Log:
trival fix to kafka-563: KafkaScheduler shutdown in ZookeeperConsumerConnector should check
for config.autocommit

Modified:
    incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala

Modified: incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala?rev=1396678&r1=1396677&r2=1396678&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala
(original)
+++ incubator/kafka/branches/0.8/core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala
Wed Oct 10 16:33:42 2012
@@ -151,7 +151,8 @@ private[kafka] class ZookeeperConsumerCo
       if (wildcardTopicWatcher != null)
         wildcardTopicWatcher.shutdown()
       try {
-        scheduler.shutdownNow()
+        if (config.autoCommit)
+          scheduler.shutdownNow()
         fetcher match {
           case Some(f) => f.shutdown
           case None =>



Mime
View raw message