Fix missing import

This commit is contained in:
Dana Powers
2016-01-30 18:24:07 -08:00
parent 47da03d90f
commit 54d21bf0f9

View File

@@ -3,6 +3,7 @@ import os
from six.moves import xrange
from . import unittest
from kafka import (
KafkaConsumer, MultiProcessConsumer, SimpleConsumer, create_message
)