diff options
author | Dana Powers <dana.powers@rd.io> | 2016-01-07 16:58:11 -0800 |
---|---|---|
committer | Dana Powers <dana.powers@rd.io> | 2016-01-07 16:59:18 -0800 |
commit | c8deb0c276d57209006eebdd910017846860a38d (patch) | |
tree | 07d0995f51689006ab324d7f4d43c4f6daebf910 /kafka | |
parent | 31c3d59ee3507a65533a3db58dd0fa59d9925b11 (diff) | |
download | kafka-python-c8deb0c276d57209006eebdd910017846860a38d.tar.gz |
Reorg kafka imports
- kafka.KafkaClient is new async client
- kafka.SimpleClient is old sync client
- update copyright / author info
- add BrokerConnection; drop KafkaConnection
Diffstat (limited to 'kafka')
-rw-r--r-- | kafka/__init__.py | 23 |
1 files changed, 12 insertions, 11 deletions
diff --git a/kafka/__init__.py b/kafka/__init__.py index 2fc59c6..2a99847 100644 --- a/kafka/__init__.py +++ b/kafka/__init__.py @@ -1,21 +1,22 @@ __title__ = 'kafka' from .version import __version__ -__author__ = 'David Arthur' +__author__ = 'Dana Powers' __license__ = 'Apache License 2.0' -__copyright__ = 'Copyright 2015, David Arthur under Apache License, v2.0' +__copyright__ = 'Copyright 2016 Dana Powers, David Arthur, and Contributors' -from kafka.client import KafkaClient -from kafka.conn import KafkaConnection +from kafka.client import KafkaClient as SimpleClient +from kafka.client_async import KafkaClient +from kafka.conn import BrokerConnection from kafka.protocol import ( - create_message, create_gzip_message, create_snappy_message -) + create_message, create_gzip_message, create_snappy_message) from kafka.producer import SimpleProducer, KeyedProducer from kafka.partitioner import RoundRobinPartitioner, HashedPartitioner, Murmur2Partitioner -from kafka.consumer import SimpleConsumer, MultiProcessConsumer, KafkaConsumer +from kafka.consumer import KafkaConsumer, SimpleConsumer, MultiProcessConsumer __all__ = [ - 'KafkaClient', 'KafkaConnection', 'SimpleProducer', 'KeyedProducer', - 'RoundRobinPartitioner', 'HashedPartitioner', 'SimpleConsumer', - 'MultiProcessConsumer', 'create_message', 'create_gzip_message', - 'create_snappy_message', 'KafkaConsumer', + 'KafkaConsumer', 'KafkaClient', 'BrokerConnection', + 'SimpleClient', 'SimpleProducer', 'KeyedProducer', + 'RoundRobinPartitioner', 'HashedPartitioner', + 'create_message', 'create_gzip_message', 'create_snappy_message', + 'SimpleConsumer', 'MultiProcessConsumer', ] |