Repository: kafka Updated Branches: refs/heads/0.10.1 5b869e7ee -> 1ba2ee80e
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/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 <[email protected]> Authored: Mon Dec 12 03:08:12 2016 +0000 Committer: Ismael Juma <[email protected]> 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() {
