My team just got started with akka-streams in Scala and we are also using Kinesis as a streaming platform. How are streams typically consumed by APIs? For instance, I want to essentially route a Kinesis stream through akka-streams through PLAY to a front-end via websockets. Should I subscribe to the kinesis stream directly in my API (probably using PLAY) and then send it over? Or is there a better way? What is the typical style for apps that consume kinesis streams?