diff --git a/kafka_scanner/__init__.py b/kafka_scanner/__init__.py
index <HASH>..<HASH> 100644
--- a/kafka_scanner/__init__.py
+++ b/kafka_scanner/__init__.py
@@ -603,10 +603,6 @@ class KafkaScannerDirect(KafkaScannerSimple):
                 self._lower_offsets = {partition: 0 for partition in self.init_consumer.offsets}
         else:
             self._lower_offsets = self.init_consumer.offsets.copy()
-        for p, o in self._lower_offsets.items():
-            if self._upper_offsets[p] < o:
-                self._lower_offsets[p] = 0
-                log.warning('Set lower offset for partition %d to 0', p)
         self.init_consumer.offsets.update(self._lower_offsets)
         self.init_consumer.count_since_commit += 1
         self.init_consumer.commit()
this code is not needed anymore with KafkaConsumer