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:59 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.11.0 b268322ed -> eda1bf6c1


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

(cherry picked from commit bf34a5b74035a90a7461ac8c8a209da450c0346b)
Signed-off-by: Ismael Juma <ismael@juma.me.uk>


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

Branch: refs/heads/0.11.0
Commit: eda1bf6c13c9966c3928b0df61f4786106395139
Parents: b268322
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:56 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/eda1bf6c/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