问WebSocket to Kafka Topic Scala API
EN

Stack Overflow用户

提问于 2019-04-04 16:46:33

回答 1查看 176关注 0票数 0

我有一个需求，我将WebSocket作为数据源，并希望将数据从WebSocket推送到Kafka topic中进行进一步处理。我不确定scala中是否有实现它的apis。因此，坚持使用这个来开始解决方案。

发布于 2019-04-04 17:39:11

在我的一个业余爱好项目(play-binding-petstore)中，我使用：

PathMsgProducer.scala做了你想要的--从websocket获取输入并将其推送到Kafka。

下面是如何将消息推送到Kafka

ProducerMessage.Message(
          new ProducerRecord(comps.config.kafkaWsPathMsgTopic, msg.username, msg.route),
          "passThrough"
        )

有关如何在Websocket中使用它，请参阅PathMsgProducer.scala。

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/55511583

复制

相似问题

问WebSocket to Kafka Topic Scala APIEN