diff options
| -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( |