我们想使用 websocket 将通过 Kafka 流接收到的消息推送到客户端。
我们最初的想法是使用 Play!Java 框架用于提供 HTTP 接口,Akka 用于反应式流处理并通过 Play 的 Iteratee 推送消息,但 Iteratee api 似乎不适用于 Play!爪哇。有解决办法吗?
我们想使用 websocket 将通过 Kafka 流接收到的消息推送到客户端。
我们最初的想法是使用 Play!Java 框架用于提供 HTTP 接口,Akka 用于反应式流处理并通过 Play 的 Iteratee 推送消息,但 Iteratee api 似乎不适用于 Play!爪哇。有解决办法吗?