diff --git a/kafka/consumer.py b/kafka/consumer.py
index f2898ad43..3d9e4d808 100644
--- a/kafka/consumer.py
+++ b/kafka/consumer.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from collections import defaultdict
 from itertools import izip_longest, repeat
 import logging
diff --git a/kafka/producer.py b/kafka/producer.py
index 7ef789684..317454830 100644
--- a/kafka/producer.py
+++ b/kafka/producer.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from collections import defaultdict
 from datetime import datetime, timedelta
 from itertools import cycle
diff --git a/kafka/queue.py b/kafka/queue.py
index a99636922..ada495f78 100644
--- a/kafka/queue.py
+++ b/kafka/queue.py
@@ -1,3 +1,5 @@
+from __future__ import absolute_import
+
 from copy import copy
 import logging
 from multiprocessing import Process, Queue, Event