diff options
| author | Carson Ip <carsonip@users.noreply.github.com> | 2019-07-14 23:22:10 +0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2019-07-14 08:22:10 -0700 |
| commit | eed25fc36110b12ec370b4d0e332173abce9076f (patch) | |
| tree | 735571279d443f339bad32d207dd8beeb6cbf2f0 | |
| parent | fb87a353d99b3271105d0941f39ee64bf2ab6858 (diff) | |
| download | kafka-python-eed25fc36110b12ec370b4d0e332173abce9076f.tar.gz | |
Fix minor typo (#1865)
| -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 |