Reorg kafka imports

Dana Powers · Dana Powers · commit c8deb0c276d5 · 2016-01-07T16:59:18.000-08:00
- kafka.KafkaClient is new async client
  - kafka.SimpleClient is old sync client
  - update copyright / author info
  - add BrokerConnection; drop KafkaConnection
diff --git 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',
 ]
