pub(crate) async fn check_topic_exists( client: &Pulsar<TokioExecutor>, topic: &Topic, ) -> ConnectorResult<()>