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-5737; KafkaAdminClient thread should be daemon
Date Wed, 16 Aug 2017 12:22:48 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 3b1cea60e -> bf34a5b74


KAFKA-5737; KafkaAdminClient thread should be daemon

Author: Colin P. Mccabe <cmccabe@confluent.io>

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

Closes #3674 from cmccabe/KAFKA-5737


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

Branch: refs/heads/trunk
Commit: bf34a5b74035a90a7461ac8c8a209da450c0346b
Parents: 3b1cea6
Author: Colin P. Mccabe <cmccabe@confluent.io>
Authored: Wed Aug 16 13:22:44 2017 +0100
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Wed Aug 16 13:22:44 2017 +0100

----------------------------------------------------------------------
 .../main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/bf34a5b7/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java b/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
index 87ede00..0ec382a 100644
--- a/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
+++ b/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
@@ -349,7 +349,7 @@ public class KafkaAdminClient extends AdminClient {
         this.client = client;
         this.runnable = new AdminClientRunnable();
         String threadName = "kafka-admin-client-thread" + (clientId.length() > 0 ? " |
" + clientId : "");
-        this.thread = new KafkaThread(threadName, runnable, false);
+        this.thread = new KafkaThread(threadName, runnable, true);
         this.timeoutProcessorFactory = (timeoutProcessorFactory == null) ?
             new TimeoutProcessorFactory() : timeoutProcessorFactory;
         this.maxRetries = config.getInt(AdminClientConfig.RETRIES_CONFIG);


Mime
View raw message