是的,Apache Flink的RabbitMQ connector使用的是org.apache.flink:flink-sql-connector-rabbitmq
库。但是,你需要确保你的项目中包含了正确的依赖项,并且这些依赖项在你的类路径中。
你提到的错误信息表明,Flink无法找到任何实现org.apache.flink.table.factories.DynamicTableFactory
接口的类,这个接口是Flink用于创建动态表的工厂接口。这可能是因为你的项目中没有包含正确的依赖项,或者这些依赖项没有在你的类路径中。
你可以尝试以下几种方法来解决这个问题:
检查你的项目依赖项,确保你已经正确地包含了
flink-sql-connector-rabbitmq
库。检查你的类路径,确保
flink-sql-connector-rabbitmq
库在你的类路径中。如果以上方法都无法解决问题,你可以尝试重新编译和部署你的项目,或者联系Flink社区寻求帮助。