关于flink集群中调用dubbo服务的咨询
i All,
目前我这里有个需求是想通过flink集群，消费mq消息，然后调用发送push的dubbo服务，实现push分发的功能。
网上关于flink接入spring框架的资料没有找到太多，更别提dubbo服务调用相关的了(也可能是我查询资料的方式有限)。
期望哪位有经验的朋友能够给予指点，我自己其实已经实现了一个测试demo，但还是期望能有更多相关资料作为参考，主要是担心资源消耗和性能、安全方面会发生问题，因为本身也是刚接触flink，了解有限。
方便的话可以提供一些实例代码或资料链接。
感谢flink社区的各位朋友*来自志愿者整理的flink邮件归档
展开
收起
1
条回答
写回答
写回答
-
Flink 任务可以调 Dubbo ，dubbo 相关初始化可以在 你的 main 方法中初始化，然后具体接口的初始化，
在你的函数中的 open 方法中进行初始化，你自己需要处理好 Dubbo 相关异常，比如超时异常。 Dubbo 的话，
会对任务处理的吞吐量有一定影响，毕竟从请求 Dubbo 到 返回数据，会消耗一定时间。*来自志愿者整理的FLINK邮件归档
2021-12-03 10:37:55赞同 展开评论 打赏
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
