我的目标是处理来自Solace的消息,并使用Dataflow上的流式Apache光束管道将结果写回Solace。
将Solace与Beam集成的推荐方式是什么?
使用MqttIO是其中一种选择。有没有更好的方法?
发布于 2018-11-08 19:17:38
我不知道是否已经为Solace和Apache Beam做了一个连接器,但我认为可能会使用Solace Java API扩展Apache Beam的streamConnector。
这里有一些很好的示例:
https://stackoverflow.com/questions/53028245
复制相似问题