From be38d553ed5442645187555a3af069138f4b8e6d Mon Sep 17 00:00:00 2001 From: chenshangan Date: Wed, 30 Jul 2014 19:59:24 +0800 Subject: [PATCH] add method to seek an absolute position --- kafka/consumer.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/kafka/consumer.py b/kafka/consumer.py index ef8fbdaac..c076d251c 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -265,6 +265,10 @@ def provide_partition_info(self): """ self.partition_info = True + def seek_absolute(self, offset): + for partition in self.offsets.keys(): + self.offsets[partition] = offset + def seek(self, offset, whence): """ Alter the current offset in the consumer, similar to fseek