Function cdc_state_key 

pub fn cdc_state_key(pipeline_name: &str) -> String

State key the CDC node will read/advance (must match the executor’s key for a root node whose id is cdc: {name}::cdc).