From eed25fc36110b12ec370b4d0e332173abce9076f Mon Sep 17 00:00:00 2001 From: Carson Ip Date: Sun, 14 Jul 2019 23:22:10 +0800 Subject: Fix minor typo (#1865) --- kafka/conn.py | 2 +- 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 -- cgit v1.2.1