@@ -191,7 +191,6 @@ def __init__(
191191 self .processed_deprecated_karapace_keys_total = 0
192192 self .last_check = time .monotonic ()
193193 self .start_time = time .monotonic ()
194- self .startup_previous_processed_offset = 0
195194 self ._replay_start_logged = False
196195
197196 self .consecutive_unexpected_errors : int = 0
@@ -388,19 +387,14 @@ def _is_ready(self) -> bool:
388387 cur_time = time .monotonic ()
389388 time_from_last_check = cur_time - self .last_check
390389 progress_pct = 0 if not self ._highest_offset else round ((self .offset / self ._highest_offset ) * 100 , 2 )
391- startup_processed_message_per_second = (
392- (self .offset - self .startup_previous_processed_offset ) / time_from_last_check if time_from_last_check > 0 else 0
393- )
394390 LOG .debug (
395- "Replay progress (%s): %s/%s (%s %%) (recs/s %s) " ,
391+ "Replay progress (%s): %s/%s (%s %%)" ,
396392 round (time_from_last_check , 2 ),
397393 self .offset ,
398394 self ._highest_offset ,
399395 progress_pct ,
400- startup_processed_message_per_second ,
401396 )
402397 self .last_check = cur_time
403- self .startup_previous_processed_offset = self .offset
404398 ready = self .offset >= self ._highest_offset
405399 if ready :
406400 self .max_messages_to_process = MAX_MESSAGES_TO_CONSUME_AFTER_STARTUP
@@ -431,7 +425,6 @@ def set_not_ready(self) -> None:
431425 now = time .monotonic ()
432426 self .start_time = now
433427 self .last_check = now
434- self .startup_previous_processed_offset = self .offset
435428 self ._replay_start_logged = False
436429
437430 @staticmethod
0 commit comments