Fix minor typo (#1865)

dpkp · Jul 14, 2019 · eed25fc · eed25fc
1 parent fb87a35
commit eed25fc
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/kafka/conn.py b/kafka/conn.py
@@ -912,7 +912,7 @@ def recv(self):
                 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
@@ -148,7 +148,7 @@ def change_subscription(self, topics):
             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