openstack/deb-python-kafka
Code Issues Proposed changes

from kafka import ConsumerRebalanceListener, OffsetAndMetadata

Browse Source
This commit is contained in:
Dana Powers
2016-09-04 09:26:41 -07:00
parent 7d31aa3978
commit 1937ce59b4
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
kafka/__init__.py
View File

@@ -19,12 +19,13 @@ logging.getLogger(__name__).addHandler(NullHandler())
from kafka.consumer import KafkaConsumer
from kafka.consumer.subscription_state import ConsumerRebalanceListener
from kafka.producer import KafkaProducer
from kafka.conn import BrokerConnection
from kafka.protocol import (
create_message, create_gzip_message, create_snappy_message)
from kafka.partitioner import RoundRobinPartitioner, HashedPartitioner, Murmur2Partitioner
from kafka.structs import TopicPartition
from kafka.structs import TopicPartition, OffsetAndMetadata
# To be deprecated when KafkaProducer interface is released
from kafka.client import SimpleClient