0

我通过 ActiveMQ 获取数据，我想使用 Apache Flink DataStreams 实时处理这些数据。支持 RabbitMQ 和 Kafka 等许多消息传递服务，但我看不到对 ActiveMQ 的任何支持。我该如何使用它？

4

2 回答 2

2

由于不支持ActiveMQ，我建议实现自定义源。

您基本上必须实现SourceFunction接口。如果您想拥有一次性语义，您可以将您的实现基于MultipleIdsMessageAcknowledgingSourceBase该类。

我建议您从实施SourceFunction

于 2016-03-17T12:57:21.350 回答
0

为 Flink 找到了一个 JMS 连接器：

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

于 2016-04-25T13:16:02.610 回答