seglo/akka-projection
The purpose of (upcoming) Akka Projections is to provide an abstraction for consuming a stream of (Event, Offset) tuples, which can originate from persisted events, Kafka topics, or other Alpakka connectors with this shape.
ScalaApache-2.0