如何在 Apache Flink 中使用 ActiveMQ？

【问题标题】：How do I use ActiveMQ in Apache Flink?如何在 Apache Flink 中使用 ActiveMQ？
【发布时间】：2019-08-29 13:59:11
【问题描述】：

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

【问题讨论】：

现在有activemq支持：github.com/apache/bahir-flink/tree/master/…

标签： activemq apache-flink flink-streaming

【解决方案1】：

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

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

我建议你从实现SourceFunction开始

【讨论】：

看看这个例子：github.com/apache/flink/blob/master/flink-streaming-connectors/…

【解决方案2】：

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

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

【讨论】：

猜你喜欢

1970-01-01
2015-02-18
1970-01-01
1970-01-01
1970-01-01
1970-01-01
1970-01-01
1970-01-01
2018-08-10

相关资源

下载 2023-02-17
下载 2023-02-15
下载 2023-01-22

最近更新更多

热门标签

Java Python linux javascript Mysql C# Docker 算法前端 SpringBoot Redis Vue spring 设计模式 .net core .net kubernetes c++ 数据库数据结构大数据 js 机器学习微服务 Android Go 程序员面试 JVM ASP.net core 云原生人工智能后端 PHP git CSS golang k8s Nginx Django mybatis 深度学习多线程 React 架构 devops 爬虫云计算 Spring Boot LeetCode