flink sql 自定义 rabbitmq connector 直接上代码 github 地址: https://github.com/liutaobigdata/flink-sql-rabbitmq-connector SourceFactory 代码 public class RabbitmqTableSourceFactory implements DynamicTableSourceFactory { private static final String FACTORY_IDENTIFIER = "rabbitmq"; public static final ConfigOption<String> QUEUE = ConfigOptions.key("queue") .stringType() .noDefaultValue(); public static final ConfigOption<String> EXCHANGE_NAME = ConfigOptions.key("exchange-name") .stringType()...