kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject git commit: kafka-900; ClosedByInterruptException when high-level consumer shutdown normally; patched by Jun Rao; reviewed by Neha Narkhede
Date Wed, 29 May 2013 16:56:38 GMT
Updated Branches:
  refs/heads/0.8 85c715915 -> 312ed2e67


kafka-900; ClosedByInterruptException when high-level consumer shutdown normally; patched
by Jun Rao; reviewed by Neha Narkhede


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/312ed2e6
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/312ed2e6
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/312ed2e6

Branch: refs/heads/0.8
Commit: 312ed2e67a0bca194ee3012c61239d30d8890566
Parents: 85c7159
Author: Jun Rao <junrao@gmail.com>
Authored: Wed May 29 09:56:27 2013 -0700
Committer: Jun Rao <junrao@gmail.com>
Committed: Wed May 29 09:56:27 2013 -0700

----------------------------------------------------------------------
 .../scala/kafka/server/AbstractFetcherThread.scala |    8 +++++---
 1 files changed, 5 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/312ed2e6/core/src/main/scala/kafka/server/AbstractFetcherThread.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/server/AbstractFetcherThread.scala b/core/src/main/scala/kafka/server/AbstractFetcherThread.scala
index 162c749..48100f4 100644
--- a/core/src/main/scala/kafka/server/AbstractFetcherThread.scala
+++ b/core/src/main/scala/kafka/server/AbstractFetcherThread.scala
@@ -152,9 +152,11 @@ abstract class AbstractFetcherThread(name: String, clientId: String,
sourceBroke
                       partitionsWithError += topicAndPartition
                   }
                 case _ =>
-                  warn("error for partition [%s,%d] to broker %d".format(topic, partitionId,
sourceBroker.id),
-                    ErrorMapping.exceptionFor(partitionData.error))
-                  partitionsWithError += topicAndPartition
+                  if (isRunning.get) {
+                    warn("error for partition [%s,%d] to broker %d".format(topic, partitionId,
sourceBroker.id),
+                      ErrorMapping.exceptionFor(partitionData.error))
+                    partitionsWithError += topicAndPartition
+                  }
               }
             }
         }


Mime
View raw message