summaryrefslogtreecommitdiff
path: root/kafka
diff options
context:
space:
mode:
authorDana Powers <dana.powers@rd.io>2016-01-07 16:58:11 -0800
committerDana Powers <dana.powers@rd.io>2016-01-07 16:59:18 -0800
commitc8deb0c276d57209006eebdd910017846860a38d (patch)
tree07d0995f51689006ab324d7f4d43c4f6daebf910 /kafka
parent31c3d59ee3507a65533a3db58dd0fa59d9925b11 (diff)
downloadkafka-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__.py23
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',
]