summaryrefslogtreecommitdiff
path: root/kafka/producer
diff options
context:
space:
mode:
authorJeff Widman <jeff@jeffwidman.com>2016-11-08 01:29:45 -0800
committerJeff Widman <jeff@jeffwidman.com>2016-11-14 03:16:41 -0800
commitcd74c1fe4053385151175b5100cb0a0d43bc31f6 (patch)
treebc430da90685195db6532311f37781ac734479e5 /kafka/producer
parent77591afa789a4752f4d385228bea980f448f6a08 (diff)
downloadkafka-python-cd74c1fe4053385151175b5100cb0a0d43bc31f6.tar.gz
Fix typos
Diffstat (limited to 'kafka/producer')
-rw-r--r--kafka/producer/base.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/producer/base.py b/kafka/producer/base.py
index 8471818..30b6fd7 100644
--- a/kafka/producer/base.py
+++ b/kafka/producer/base.py
@@ -104,7 +104,7 @@ def _send_upstream(queue, client, codec, batch_time, batch_size,
msgset = defaultdict(list)
# Merging messages will require a bit more work to manage correctly
- # for now, dont look for new batches if we have old ones to retry
+ # for now, don't look for new batches if we have old ones to retry
if request_tries:
count = 0
log.debug('Skipping new batch collection to handle retries')