diff --git a/kafka/consumer/__init__.py b/kafka/consumer/__init__.py index 935f56e..8041537 100644 --- a/kafka/consumer/__init__.py +++ b/kafka/consumer/__init__.py @@ -1,6 +1,6 @@ from .simple import SimpleConsumer from .multiprocess import MultiProcessConsumer -from .kafka import KafkaConsumer +from .group import KafkaConsumer __all__ = [ 'SimpleConsumer', 'MultiProcessConsumer', 'KafkaConsumer'