Merge pull request #787 from carsonip/patch-1

Minor typo fix
Parsely · Apr 23, 2018 · 410bcf1 · 410bcf1
2 parents 6687224 + 9615766
commit 410bcf1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pykafka/producer.py b/pykafka/producer.py
@@ -273,7 +273,7 @@ def _setup_owned_brokers(self):
                 owned_broker = self._owned_brokers.pop(broker)
                 owned_broker.stop()
 
-                # loop becuase flush is not garentee to empty owned
+                # loop because flush is not guaranteed to empty owned
                 # broker queue
                 while True:
                     batch = owned_broker.flush(self._linger_ms,