websocket到kafka主题scala api

n3h0vuf2 于 2021-06-06 发布在 Kafka

关注(0)|答案(1)|浏览(265)

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

1条答案

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

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

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