TopicPartition should be importable from top-level module
This commit is contained in:
@@ -22,6 +22,7 @@ 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.common import TopicPartition
|
||||
|
||||
# To be deprecated when KafkaProducer interface is released
|
||||
from kafka.client import SimpleClient
|
||||
|
Reference in New Issue
Block a user