我通过activemq获取数据，我想用apache flink数据流实时处理它。有许多消息服务支持，比如rabbitmq和kafka，但是我看不到对activemq的任何支持。我怎么用？
iih3973s1#
因为不支持 ActiveMQ ，我建议实现一个自定义源代码。你基本上必须实现 SourceFunction 接口。如果您希望只使用一次语义，那么可以基于 MultipleIdsMessageAcknowledgingSourceBase 班级。我建议您从实施 SourceFunction
ActiveMQ
SourceFunction
MultipleIdsMessageAcknowledgingSourceBase
tzcvj98z2#
找到flink的jms连接器：https://github.com/jkirsch/senser/blob/master/src/main/java/edu/tuberlin/senser/images/flink/io/flinkjmsstreamsource.java
2条答案
按热度按时间iih3973s1#
因为不支持
ActiveMQ，我建议实现一个自定义源代码。你基本上必须实现
SourceFunction接口。如果您希望只使用一次语义，那么可以基于MultipleIdsMessageAcknowledgingSourceBase班级。我建议您从实施
SourceFunctiontzcvj98z2#
找到flink的jms连接器：
https://github.com/jkirsch/senser/blob/master/src/main/java/edu/tuberlin/senser/images/flink/io/flinkjmsstreamsource.java