WebSocket для Kafka Тема Scala API

Question

У меня есть требование, когда я использую WebSocket в качестве источника данных и хочу перенести данные из WebSocket в тему Kafka для дальнейшей обработки.Я не уверен, что в scala есть какой-либо apis для его достижения.Так что застряли с этим, чтобы начать с решения.

Answer 1

В одном из моих хобби-проектов ( play -inding-petstore ) я использовал:

Альпакка Кафка

PathMsgProducer.scala делает то, что вы просите - получает ввод из веб-сокета и помещает его в Kafka.

Вот как отправить сообщение на Kafka:

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

См. PathMsgProducer.scala о том, как использовать его в Websocket.