-record(connector_plan, {
    name :: binary(),
    source :: lightspeed@pipeline@connector:source_connector(),
    sink :: lightspeed@pipeline@connector:sink_connector(),
    retry_policy :: lightspeed@pipeline@connector:retry_policy(),
    dead_letter_policy :: lightspeed@pipeline@connector:dead_letter_policy(),
    reprocess_window :: gleam@option:option(lightspeed@pipeline@connector:reprocess_window()),
    max_batch_records :: integer()
}).