Je suis très nouveau à Akka Streaming et le streaming réactif. J'ai une question: est-il possible d'avoir une API de repos recevant un message le déposant sur Kafka Bus, et le consommateur de streaming Kafka agrège alors les messages dans un max. fenêtre temporelle et retrun la réponse en arrière?Flux réactif Kafka Stream Fan-out à acteurs http
Comment implémenter un tel système? Ou par où commencer?
Merci
Pour une API de repos, vous pouvez considérer le Kafka REST Proxy: https://github.com/confluentinc/kafka-rest Ou bien sûr, vous pouvez construire votre propre place à l'aide d'Akka-http et akka-stream-kafka.
Quant à fenêtrage, je suis sûr que cela peut être fait dans les flux AKKA mais personnellement, je suggère d'utiliser Kafka cours d'eau comme le premier port d'escale: http://docs.confluent.io/current/streams/developer-guide.html#windowing
Je ne sais pas exactement ce que vous Cela signifie renvoyer la réponse, mais si vous suivez l'approche ci-dessus, vous pouvez utiliser REST Proxy pour consommer les messages agrégés fenêtrés ou vous pouvez créer un service REST qui interroge les magasins d'état Kafka Streams via les requêtes interactives. ". Ce post montre comment le faire en utilisant javax.ws.rs: https://www.confluent.io/blog/unifying-stream-processing-and-interactive-queries-in-apache-kafka/ mais pour une application réactive, vous pouvez faire la même chose en utilisant akka-http à la place (j'implémente cette chose sur un de mes projets).