如何使用 Apache Beam 从 Solace 摄取消息并将消息发布到 Solace？

【问题标题】：How to ingest messages from and publish messages to Solace using Apache Beam?如何使用 Apache Beam 从 Solace 摄取消息并将消息发布到 Solace？
【发布时间】：2018-11-08 19:17:37
【问题描述】：

我的目标是处理来自 Solace 的消息，并使用 Dataflow 上的流式 Apache Beam 管道将结果写回 Solace。

将 Solace 与 Beam 集成的推荐方法是什么？

使用MqttIO 是其中一种选择。有没有更好的办法？

【问题讨论】：

标签： google-cloud-dataflow apache-beam solace

【解决方案1】：

我不知道是否已经为 Solace 和 Apache Beam 完成了连接器，但我认为可能会使用 Solace Java API 扩展 Apache Beam 的 streamConnector。

这里有一些很好的示例：

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

【讨论】：