diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-03 16:14:37 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-03 16:14:37 -0800 |
| commit | 0334fee5509b8cb3fd6ca3c1a6025804be978107 (patch) | |
| tree | ee24e1eb66c4b077cd3c51123afcf9bda3c05846 | |
| parent | df75751238f2ccc731d9881c92dfcc524c57aeaf (diff) | |
| download | kafka-python-0334fee5509b8cb3fd6ca3c1a6025804be978107.tar.gz | |
Switch to new KafkaConsumer in module imports
| -rw-r--r-- | kafka/consumer/__init__.py | 2 |
1 files changed, 1 insertions, 1 deletions
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' |