New to Akka? Start with the Akka SDK.

Akka Projection

Overview
- Dependencies
- Contributing
Use Cases
- Command Query Responsibility Segregation (CQRS)
- Service to service communication
Getting Started Guide
- Video Introduction
- Setup your application
- Choosing a Source Provider
- Build a Projection handler
- Writing tests for a Projection
- Running the Projection
- Running the Projection in Akka Cluster
Events from Akka Persistence
- Dependencies
- SourceProvider for eventsByTag
- SourceProvider for eventsBySlices
- SourceProvider for eventsBySlicesStartingFromSnapshots
- Many Projections
Changes from Durable State
- Dependencies
- SourceProvider for changesByTag
- SourceProvider for changesBySlices
- SourceProvider for eventsBySlices
Messages from and to Kafka
- Dependencies
- KafkaSourceProvider
- Committing offset outside Kafka
- Committing offset in Kafka
- Sending to Kafka
- Mergeable Offset
- Configuration
Offset in a relational DB with R2DBC
- Dependencies
- Schema
- Configuration
- Running with Sharded Daemon Process
- Slices
- exactly-once
- at-least-once
- groupedWithin
- Handler
- Offset types
- Publish events for lower latency
- Multiple plugins
- Custom Connection Factory
Offset in Cassandra
- Dependencies
- at-least-once
- at-most-once
- groupedWithin
- Handler
- Schema
- Offset types
- Configuration
Offset in a relational DB with JDBC
- Dependencies
- Required configuration settings
- Defining a JdbcSession
- Blocking JDBC Dispatcher
- exactly-once
- at-least-once
- groupedWithin
- Handler
- Schema
- Offset types
- Configuration
Offset in a relational DB with Slick
- Dependencies
- exactly-once
- at-least-once
- groupedWithin
- Handler
- Schema
- Offset types
- Configuration
Offset in DynamoDB
- Dependencies
- Tables
- Configuration
- Running with Sharded Daemon Process
- Slices
- exactly-once
- at-least-once
- exactly-once (grouped)
- at-least-once (grouped)
- Handler
- Publish events for lower latency
- Multiple plugins
- Time to Live (TTL)
Running a Projection
- Dependencies
- Running with Sharded Daemon Process
- Running with local Actor
- Running in Cluster Singleton
Processing with Actor
Processing with Akka Streams
Error handling
- Handler recovery
- Projection restart
Projection Settings
- Configuration
Akka Projection gRPC
- Overview
- Dependencies
- Consumer
- Producer
- Filters
- Sample projects
- Security
- Access control
- Performance considerations
- Configuration
Akka Projection gRPC with producer push
- Overview
- Dependencies
- Consumer set up
- Producer set up
Akka Replicated Event Sourcing over gRPC
- Overview
- Dependencies
- API and setup
- Serialization of events
- Filters
- Sample projects
- Security
- Access control
- Migrating from non-replicated
Management of a Projection
- Offset management
- Pause and resume
- Status tracking
Testing
- Dependencies
- Initializing the Projection TestKit
- Testing with an assert function
- Testing with a TestSink probe
- Testing with mocked Projection and SourceProvider
Akka Classic
- Actor System
- PersistentActor
- Running
Snapshots
- Configure repository
- Documentation