def __init__()

in consumer/record_processor.py [0:0]

• 7 lines of code
• 1 McCabe index (conditional complexity)

    def __init__(self):
        self._SLEEP_SECONDS = 5
        self._CHECKPOINT_RETRIES = 5
        self._CHECKPOINT_FREQ_SECONDS = 60
        self._largest_seq = (None, None)
        self._largest_sub_seq = None
        self._last_checkpoint_time = None