我对 Akka 流媒体和反应式流媒体很陌生。我有一个问题：是否可以让 rest API 接收到将其丢弃在 Kafka Bus 上的消息，然后 Kafka 流消费者在最大时间窗口中聚合消息并重新运行答案？
如何实施这样的系统？或者从哪里开始？
谢谢
对于 rest API，您可以考虑使用 Kafka REST 代理： https://github.com/confluentinc/kafka-rest或者当然，你可以使用 akka-http 和 akka-stream-kafka 构建自己的。
至于窗口化，我相信它可以在 akka 流中完成，但就个人而言，我建议使用 Kafka 流作为第一个停靠港：http://docs.confluent.io/current/streams/developer-guide.html#windowing
我不确定你返回答案到底是什么意思，但如果你遵循上面的方法，你可以使用 REST 代理来使用窗口聚合的消息，或者你可以构建一个 REST 服务，通过所谓的"交互式查询"查询 Kafka Streams 状态存储。这篇文章展示了如何使用 javax.ws.rs 来做到这一点：https://www.confluent.io/blog/unifying-stream-processing-and-interactive-queries-in-apache-kafka/但对于反应式应用程序，你可以使用 akka-http 来做同样的事情(我正在我的一个项目中实现这个确切的事情(。