diff options
| author | Dana Powers <dana.powers@gmail.com> | 2019-05-29 21:20:21 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2019-05-29 21:20:21 -0700 |
| commit | 12414f407f6635f5e20a42fa56d9f81e0a35cdf1 (patch) | |
| tree | 8343cf596fc672487cecca82c5b0c1dbbebbfda4 | |
| parent | c5626897ebdfca6cf8a55e36308ad3b4d76a05d8 (diff) | |
| download | kafka-python-separate_coordinator_conn.tar.gz | |
| -rw-r--r-- | kafka/cluster.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/cluster.py b/kafka/cluster.py index 5d40e8c..a50e88a 100644 --- a/kafka/cluster.py +++ b/kafka/cluster.py @@ -355,7 +355,7 @@ class ClusterMetadata(object): self._groups[group] = -1 return - # Use a coordinator-specific node id so that group requuests + # Use a coordinator-specific node id so that group requests # get a dedicated connection node_id = 'coordinator-{}'.format(response.coordinator_id) coordinator = BrokerMetadata( |