TopicPartition should be importable from top-level module

dpkp · dpkp · commit c0d6273419c8 · 2016-02-15T12:45:50.000-08:00
diff --git a/kafka/__init__.py b/kafka/__init__.py
@@ -22,6 +22,7 @@ def emit(self, record):
 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
