diff options
| -rw-r--r-- | kafka/conn.py | 2 | ||||
| -rw-r--r-- | kafka/consumer/subscription_state.py | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index 825406c..80ece87 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -912,7 +912,7 @@ class BrokerConnection(object): self.config['request_timeout_ms'])) return () - # augment respones w/ correlation_id, future, and timestamp + # augment responses w/ correlation_id, future, and timestamp for i, (correlation_id, response) in enumerate(responses): try: with self._lock: diff --git a/kafka/consumer/subscription_state.py b/kafka/consumer/subscription_state.py index ef50166..76a6c50 100644 --- a/kafka/consumer/subscription_state.py +++ b/kafka/consumer/subscription_state.py @@ -148,7 +148,7 @@ class SubscriptionState(object): topics (list of str): topics for subscription Raises: - IllegalStateErrror: if assign_from_user has been used already + IllegalStateError: if assign_from_user has been used already TypeError: if a topic is None or a non-str ValueError: if a topic is an empty string or - a topic name is '.' or '..' or |