Merge pull request #66 from jcrobak/fix-import-collision

Enable absolute imports for modules using Queue.

kafka/consumer.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from collections import defaultdict
 from itertools import izip_longest, repeat
 import logging

kafka/producer.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from collections import defaultdict
 from itertools import cycle
 from multiprocessing import Queue, Process

kafka/queue.py

@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from copy import copy
 import logging
 from multiprocessing import Process, Queue, Event