summaryrefslogtreecommitdiff
path: root/kafka/client.py
diff options
context:
space:
mode:
Diffstat (limited to 'kafka/client.py')
-rw-r--r--kafka/client.py3
1 files changed, 2 insertions, 1 deletions
diff --git a/kafka/client.py b/kafka/client.py
index a31ea66..965cbc5 100644
--- a/kafka/client.py
+++ b/kafka/client.py
@@ -1,9 +1,10 @@
from collections import defaultdict
from functools import partial
+from itertools import count
import logging
import time
-from kafka.common import count, ErrorMapping, TopicAndPartition
+from kafka.common import ErrorMapping, TopicAndPartition
from kafka.conn import KafkaConnection
from kafka.protocol import KafkaProtocol