handle_reset_source

risingwave_frontend::handler::reset_source

Function handle_reset_source 

Source 
pub async fn handle_reset_source(
    handler_args: HandlerArgs,
    name: ObjectName,
) -> Result<RwPgResponse>
Expand description

Handle RESET SOURCE source_name command This command is used to reset CDC source offset to the latest position when the original offset has expired in the upstream binlog/oplog.