开发者社区> 问答> 正文

连接rabbitmq的时候java有很多包支持,想问一下pyflink有类似的连接支持么?

我是一个flink的初学者。目前的需求是从rabbitmq读入流处理后存进mysql。 因为公司大家的技术栈是python,最近看到了中国社区在推广pyflink(apache-flink)所以就试了一下。但是我发现连接rabbitmq的时候,java有很多包支持,比如 org.apache.flink.streaming.connectors.rabbitmq.* ,想问一下pyflink有类似的连接支持么?

或者有什么推荐的解决方案么比如用pika连接等*来自志愿者整理的FLINK邮件归档

展开
收起
玛丽莲梦嘉 2021-12-03 18:33:13 1130 0
1 条回答
写回答
取消 提交回答
问答排行榜
最热
最新

相关电子书

更多
Spring Cloud Alibaba - 重新定义 Java Cloud-Native 立即下载
The Reactive Cloud Native Arch 立即下载
JAVA开发手册1.5.0 立即下载