Как использовать ActiveMQ в Apache Flink?

Question

Я получаю свои данные через ActiveMQ, которые я хочу обрабатывать в реальном времени с помощью Apache Flink DataStreams. Существует поддержка многих служб обмена сообщениями, таких как RabbitMQ и Kafka, но я не вижу никакой поддержки ActiveMQ. Как я могу использовать его?

Answer 1

Нашли разъем JMS для Флинка:

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

Answer 2

Поскольку нет поддержки для ActiveMQ, я бы рекомендовал реализовать пользовательский источник.

Вы в основном должны реализовать интерфейс SourceFunction. Если вы хотите иметь семантику ровно один раз, вы можете создать свою реализацию на классе MultipleIdsMessageAcknowledgingSourceBase.

Я бы порекомендовал вам начать с реализации SourceFunction