pub async fn append<R>( addr: &str, topic: &str, data: R, meta: Option<&Value>, ttl: Option<TTL>, context: Option<&str>, ) -> Result<Bytes, Box<dyn Error + Send + Sync>>where R: AsyncRead + Unpin + Send + 'static,