kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject [11/40] git commit: kafka-900; ClosedByInterruptException when high-level consumer shutdown normally; patched by Jun Rao; reviewed by Neha Narkhede
Date Thu, 11 Jul 2013 06:37:21 GMT
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/trunk
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

----------------------------------------------------------------------
 core/src/main/scala/kafka/server/AbstractFetcherThread.scala | 8 +++++---
 1 file 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