From 6441a5bb9413aa30404c8c7d45c5ff860dc5d977 Mon Sep 17 00:00:00 2001
From: shawnsarwar <shawn.sarwar@ehealthnigeria.org>
Date: Mon, 30 Nov 2020 11:30:33 +0100
Subject: [PATCH] fix: kafka seek to beginning now takes a list (#26)

* fix: use seek to set partition offset
---
 aet/kafka.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/aet/kafka.py b/aet/kafka.py
index b681c19..de8fd1a 100644
--- 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)