fix: kafka seek to beginning now takes a list (#26)

* fix: use seek to set partition offset
eHealthAfrica · Nov 30, 2020 · 6441a5b · 6441a5b
1 parent b620552
commit 6441a5b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/aet/kafka.py b/aet/kafka.py
@@ -323,4 +323,4 @@ def seek_to_beginning(self):
         partitions = self.assignment()
         for p in partitions:
             p.offset = confluent_kafka.OFFSET_BEGINNING
-            super(KafkaConsumer, self).assign(p)
+            super(KafkaConsumer, self).seek(p)