Repository: kafka Updated Branches: refs/heads/trunk 62e043a86 -> f0acc4a0d
KAFKA-4431; Make consumer heartbeat thread a daemon thread Author: Rajini Sivaram <[email protected]> Reviewers: Ismael Juma <[email protected]> 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 <[email protected]> Authored: Mon Dec 12 03:08:12 2016 +0000 Committer: Ismael Juma <[email protected]> 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() {
