include/lightspeed@pipeline@connector_ReprocessWindow.hrl

-record(reprocess_window, {
    start_sequence :: integer(),
    end_sequence :: integer(),
    reason :: binary()
}).