Function start_processor 

pub fn start_processor(
    pubsub: Arc<PubSubManager>,
    buffer_size: usize,
) -> CDCHandle

Start a CDC processor and return a handle for sending events.

This spawns a background task that processes CDC events.