from __future__ import absolute_import from kafka.consumer.group import KafkaConsumer __all__ = [ 'KafkaConsumer' ]