call _consume_topic_partition() before storing offset

in KafkaConsumer.set_topic_partitions((topic, partition, offset))

1 files changed, 1 insertions, 1 deletions

diff --git a/kafka/consumer/kafka.py b/kafka/consumer/kafka.py
index 59597d9..423ba63 100644
--- a/kafka/consumer/kafka.py
+++ b/kafka/consumer/kafka.py
@@ -194,10 +194,10 @@ class KafkaConsumer(object):
             elif isinstance(arg, tuple):
                 topic = kafka_bytestring(arg[0])
                 partition = arg[1]
+                self._consume_topic_partition(topic, partition)
                 if len(arg) == 3:
                     offset = arg[2]
                     self._offsets.fetch[(topic, partition)] = offset
-                self._consume_topic_partition(topic, partition)
 
             # { topic: partitions, ... } dict
             elif isinstance(arg, dict):