inject_source_offsets

risingwave_ctl::cmd_impl::meta::source_props

Function inject_source_offsets 

Source 
pub async fn inject_source_offsets(
    context: &CtlContext,
    source_id: u32,
    offsets_json: String,
) -> Result<()>
Expand description

Inject specific offsets into source splits.

WARNING: This is an UNSAFE operation that may cause data duplication or loss! Use with extreme caution and only when you know the exact offsets needed.