Function init_jetstream 

pub async fn init_jetstream(
    conn: &Connection,
    bucket: &str,
) -> Result<(), Error>

Initialize JetStream context and create KV bucket if missing