Function mz_storage_client::sink::determine_sink_resume_upper

pub async fn determine_sink_resume_upper(
    sink_id: GlobalId,
    connection: &KafkaSinkConnection,
    storage_configuration: &StorageConfiguration
) -> Result<Option<Antichain<Timestamp>>, ContextCreationError>

Determines the latest progress record from the specified topic for the given progress key.

IMPORTANT: to achieve exactly once guarantees, the producer that will resume production at the returned timestamp must have called init_transactions prior to calling this method.