【发布时间】：2020-04-09 15:19:50
【问题描述】：
我有一个要求，我将 WebSocket 作为数据源，并希望将数据从 WebSocket 推送到 Kafka 主题中以进行进一步处理。我不确定scala中是否有任何api来实现它。所以坚持这个开始解决方案。
【问题讨论】：
标签： scala apache-kafka
【发布时间】：2020-04-09 15:19:50
【问题描述】：
在我的一个爱好项目 (play-binding-petstore) 中，我使用了：
PathMsgProducer.scala 满足您的要求 - 从 websocket 获取输入并将其推送到 Kafka。
这里是如何将消息推送到Kafka：
ProducerMessage.Message(
new ProducerRecord(comps.config.kafkaWsPathMsgTopic, msg.username, msg.route),
"passThrough"
)
请参阅PathMsgProducer.scala，了解如何在 Websocket 中使用它。
【讨论】：
-
你能建议如何在 Java 上做到这一点.. 基本上，我正在寻找一个连接器（我需要自定义一点）来从 websockets 中读取并写入主题..
-
akka 的所有内容都可用于 Scala 和 Java - 只需查看可以切换到 Java 的文档。