You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2016/12/12 03:08:20 UTC
kafka git commit: KAFKA-4431;
Make consumer heartbeat thread a daemon thread
Repository: kafka
Updated Branches:
refs/heads/trunk 62e043a86 -> f0acc4a0d
KAFKA-4431; Make consumer heartbeat thread a daemon thread
Author: Rajini Sivaram <ra...@googlemail.com>
Reviewers: Ismael Juma <is...@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/f0acc4a0
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/f0acc4a0
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/f0acc4a0
Branch: refs/heads/trunk
Commit: f0acc4a0dd49c80929c36a073733c0147b2cd64a
Parents: 62e043a
Author: Rajini Sivaram <ra...@googlemail.com>
Authored: Mon Dec 12 03:08:12 2016 +0000
Committer: Ismael Juma <is...@juma.me.uk>
Committed: Mon Dec 12 03:08:12 2016 +0000
----------------------------------------------------------------------
.../kafka/clients/consumer/internals/AbstractCoordinator.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/f0acc4a0/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 c9888a1..cdea51f 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
@@ -784,6 +784,7 @@ public abstract class AbstractCoordinator implements Closeable {
HeartbeatThread() {
super("kafka-coordinator-heartbeat-thread" + (groupId.isEmpty() ? "" : " | " + groupId));
+ setDaemon(true);
}
public void enable() {