kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: KAFKA-4431; Make consumer heartbeat thread a daemon thread
Date Wed, 14 Dec 2016 15:05:38 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.1 5b869e7ee -> 1ba2ee80e


KAFKA-4431; Make consumer heartbeat thread a daemon thread

Author: Rajini Sivaram <rajinisivaram@googlemail.com>

Reviewers: Ismael Juma <ismael@juma.me.uk>

Closes #2234 from rajinisivaram/KAFKA-4431


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

Branch: refs/heads/0.10.1
Commit: 1ba2ee80e06470aed367e3b0dcae6d13f1240a75
Parents: 5b869e7
Author: Rajini Sivaram <rajinisivaram@googlemail.com>
Authored: Mon Dec 12 03:08:12 2016 +0000
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Wed Dec 14 06:56:19 2016 -0800

----------------------------------------------------------------------
 .../kafka/clients/consumer/internals/AbstractCoordinator.java       | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/1ba2ee80/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
index 73543ad..93b92bb 100644
--- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
+++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
@@ -810,6 +810,7 @@ public abstract class AbstractCoordinator implements Closeable {
 
         HeartbeatThread() {
             super("kafka-coordinator-heartbeat-thread" + (groupId.isEmpty() ? "" : " | "
+ groupId));
+            setDaemon(true);
         }
 
         public void enable() {


Mime
View raw message