kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject kafka git commit: MINOR: Give a name to the coordinator heartbeat thread
Date Wed, 14 Sep 2016 16:16:39 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 41e676d29 -> f2cd17010


MINOR: Give a name to the coordinator heartbeat thread

Followed the same naming pattern as the producer sender thread.

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

Reviewers: Jason Gustafson

Closes #1854 from ijuma/heartbeat-thread-name


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

Branch: refs/heads/trunk
Commit: f2cd17010267b0e219d339d4bbc1157f5290cdfe
Parents: 41e676d
Author: Ismael Juma <ismael@juma.me.uk>
Authored: Wed Sep 14 09:16:29 2016 -0700
Committer: Jason Gustafson <jason@confluent.io>
Committed: Wed Sep 14 09:16:29 2016 -0700

----------------------------------------------------------------------
 .../kafka/clients/consumer/internals/AbstractCoordinator.java    | 4 ++++
 1 file changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/f2cd1701/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 7ae79c0..2f36239 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
@@ -793,6 +793,10 @@ public abstract class AbstractCoordinator implements Closeable {
         private boolean closed = false;
         private AtomicReference<RuntimeException> failed = new AtomicReference<>(null);
 
+        HeartbeatThread() {
+            super("kafka-coordinator-heartbeat-thread" + (groupId.isEmpty() ? "" : " | "
+ groupId));
+        }
+
         public void enable() {
             synchronized (AbstractCoordinator.this) {
                 this.enabled = true;


Mime
View raw message