Function init_with_committer_watermark 

pub async fn init_with_committer_watermark(
    connection: &mut impl Connection,
    pipeline_task: &str,
    init_watermark: InitWatermark,
) -> Result<InitWatermark>

A utility function for connections that do not have special initialization logic. These connections delegate initialization to Connection::committer_watermark.