如何在Apache Flink中使用ActiveMQ?


0

我通过ActiveMQ获取数据,我想用Apache Flink数据流实时处理它。有许多消息服务支持,比如RabbitMQ和Kafka,但是我看不到对ActiveMQ的任何支持。我怎么用?

2 答案


0

由于不支持ActiveMQ,我建议实现一个自定义源代码。

您基本上必须实现SourceFunction接口。

我建议您从实现SourceFunction开始


0

找到Flink的JMS join器:

https://github.com/jkirsch/senser/blob/master/src/main/java/edu/tuberlin/senser/images/flink/io/FlinkJMSStreamSource.java


我来回答

写文章

提问题

面试题