Function mz_storage::sink::kafka::determine_sink_progress

async fn determine_sink_progress(
    sink_id: GlobalId,
    connection: &KafkaSinkConnection,
    storage_configuration: &StorageConfiguration,
    metrics: Arc<KafkaSinkMetrics>,
) -> Result<Option<ProgressRecord>, 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.