diff --git a/extras/opl/skip_to_end.py b/extras/opl/skip_to_end.py index 51801f0..fb790ca 100755 --- a/extras/opl/skip_to_end.py +++ b/extras/opl/skip_to_end.py @@ -26,7 +26,7 @@ def doit_seek_to_end(args): # Seek to end for attempt in range(10): try: - consumer.poll(timeout_ms=0) + consumer.poll(timeout_ms=5000) consumer.seek_to_end() except AssertionError as e: logging.warning(f"Retrying as seek to end failed with: {e}")