pub async fn create_prod_stream(topic: &str) -> Result<Stream>
Helper to create a stream with production settings