Skip to content

Commit 13490fa

Browse files
authored
Name heartbeat thread with group_id; use backoff when polling (#1345)
1 parent 34fea65 commit 13490fa

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kafka/coordinator/base.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -882,7 +882,7 @@ def __init__(self, heartbeat, metrics, prefix, tags=None):
882882
class HeartbeatThread(threading.Thread):
883883
def __init__(self, coordinator):
884884
super(HeartbeatThread, self).__init__()
885-
self.name = threading.current_thread().name + '-heartbeat'
885+
self.name = coordinator.group_id + '-heartbeat'
886886
self.coordinator = coordinator
887887
self.enabled = False
888888
self.closed = False

0 commit comments

Comments
 (0)