Как принимать сообщения от Solace и публиковать их с помощью Apache Beam?

Question

Моя цель - обработать сообщения от Solace и записать результаты обратно в Solace, используя потоковый конвейер Apache Beam в Dataflow.

Каков рекомендуемый способ интеграции Solace с Beam?

Использование MqttIO является одним из вариантов.Есть ли лучший способ?

Answer 1

Я не знаю, есть ли уже созданный коннектор для Solace и Apache Beam, но я думаю, что возможно расширение streamConnector Apache Beam с помощью API-интерфейсов Solace Java.

Здесь есть несколько хороших образцов:

https://docs.solace.com/APIs.htm