pub async fn init_jetstream(conn: &Client, bucket: &str) -> Result<(), Error>
Initialize JetStream context and create KV bucket if missing