openstack/deb-python-kafka
Code Issues Proposed changes

Reorg kafka imports

Browse Source 
- kafka.KafkaClient is new async client
  - kafka.SimpleClient is old sync client
  - update copyright / author info
  - add BrokerConnection; drop KafkaConnection
This commit is contained in:
Dana Powers
2016-01-07 16:58:11 -08:00
parent 31c3d59ee3
commit c8deb0c276
1 changed files with 12 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
kafka/__init__.py
View File

@@ -1,21 +1,22 @@
__title__ = 'kafka' __title__ = 'kafka'
from .version import __version__ from .version import __version__
__author__ = 'David Arthur' __author__ = 'Dana Powers'
__license__ = 'Apache License 2.0' __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.client import KafkaClient as SimpleClient
from kafka.conn import KafkaConnection from kafka.client_async import KafkaClient
from kafka.conn import BrokerConnection
from kafka.protocol import ( 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.producer import SimpleProducer, KeyedProducer
from kafka.partitioner import RoundRobinPartitioner, HashedPartitioner, Murmur2Partitioner from kafka.partitioner import RoundRobinPartitioner, HashedPartitioner, Murmur2Partitioner
from kafka.consumer import SimpleConsumer, MultiProcessConsumer, KafkaConsumer from kafka.consumer import KafkaConsumer, SimpleConsumer, MultiProcessConsumer
__all__ = [ __all__ = [
'KafkaClient', 'KafkaConnection', 'SimpleProducer', 'KeyedProducer', 'KafkaConsumer', 'KafkaClient', 'BrokerConnection',
'RoundRobinPartitioner', 'HashedPartitioner', 'SimpleConsumer', 'SimpleClient', 'SimpleProducer', 'KeyedProducer',
'MultiProcessConsumer', 'create_message', 'create_gzip_message', 'RoundRobinPartitioner', 'HashedPartitioner',
'create_snappy_message', 'KafkaConsumer', 'create_message', 'create_gzip_message', 'create_snappy_message',
'SimpleConsumer', 'MultiProcessConsumer',
] ]