您好~ 我是一个flink的初学者。目前的需求是从rabbitmq读入流处理后存进mysql。 因为公司大家的技术栈是python，最近看到了中国社区在推广pyflink（apache-flink）所以就试了一下。但是我发现连接rabbitmq的时候，java有很多包支持，比如 org.apache.flink.streaming.connectors.rabbitmq.* ，想问一下pyflink有类似的连接支持么？
或者有什么推荐的解决方案么比如用pika连接等 多谢~ -- Ella Sun
