websocket到kafka主题scala api

n3h0vuf2  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(277)

我有一个要求,我有websocket作为数据源,并希望将数据从websocket推到kafka主题中进行进一步处理。我不确定scala中是否有API来实现它。所以,坚持这一点,开始解决问题。

v64noz0r

v64noz0r1#

在我的一个爱好项目(play binding petstore)中,我使用了:
Kafka
scala执行您要求的操作-从websocket获取输入并将其推送到 Kafka .
下面是如何将消息推送到 Kafka :

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

看到了吗 PathMsgProducer.scala 如何在websocket中使用它。

相关问题