summaryrefslogtreecommitdiff
path: root/kafka/common.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@rd.io>2015-12-21 01:37:25 -0800
committerDana Powers <dana.powers@rd.io>2015-12-28 13:44:29 -0800
commitc9e6f17e42e410adfe583d987c516149bdcdcdae (patch)
tree9ec12383f55c9dcd001516f6982e4437af4de408 /kafka/common.py
parentfd1801907f85ac7686b9452c08ae908c3a88cd51 (diff)
downloadkafka-python-c9e6f17e42e410adfe583d987c516149bdcdcdae.tar.gz
Rename TopicAndPartition -> TopicPartition
Diffstat (limited to 'kafka/common.py')
-rw-r--r--kafka/common.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/common.py b/kafka/common.py
index f79150b..6a32372 100644
--- a/kafka/common.py
+++ b/kafka/common.py
@@ -72,7 +72,7 @@ OffsetAndMessage = namedtuple("OffsetAndMessage",
Message = namedtuple("Message",
["magic", "attributes", "key", "value"])
-TopicAndPartition = namedtuple("TopicAndPartition",
+TopicPartition = namedtuple("TopicPartition",
["topic", "partition"])
KafkaMessage = namedtuple("KafkaMessage",