Find centralized, trusted content and collaborate around the technologies you use most.
Teams
Q&A for work
Connect and share knowledge within a single location that is structured and easy to search.
我通过 ActiveMQ 获取数据,我想使用 Apache Flink DataStreams 实时处理这些数据。支持 RabbitMQ 和 Kafka 等许多消息传递服务,但我看不到对 ActiveMQ 的任何支持。我该如何使用它?
由于不支持ActiveMQ,我建议实现自定义源。
ActiveMQ
您基本上必须实现SourceFunction接口。如果您想拥有一次性语义,您可以将您的实现基于MultipleIdsMessageAcknowledgingSourceBase该类。
SourceFunction
MultipleIdsMessageAcknowledgingSourceBase
我建议您从实施SourceFunction
为 Flink 找到了一个 JMS 连接器:
https://github.com/jkirsch/senser/blob/master/src/main/java/edu/tuberlin/senser/images/flink/io/FlinkJMSStreamSource.java