Apache Pekko 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 Apache Pekko Cluster
Events from Apache Pekko Persistence
- Dependencies
- SourceProvider for eventsByTag
- SourceProvider for eventsBySlices
Changes from Durable State
- Dependencies
- SourceProvider for changesByTag
- SourceProvider for changesBySlices
Messages from and to Apache Kafka
- Dependencies
- KafkaSourceProvider
- Committing offset outside Kafka
- Committing offset in Kafka
- Sending to Kafka
- Mergeable Offset
- Configuration
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
Running a Projection
- Dependencies
- Running with Sharded Daemon Process
- Running with local Actor
- Running in Cluster Singleton
Processing with Actor
Processing with Apache Pekko Streams
Error handling
- Handler recovery
- Projection restart
Projection Settings
- Configuration
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 TestSubscriber.Probe
- Testing with mocked Projection and SourceProvider
Pekko Classic
- Actor System
- PersistentActor
- Running
Release Notes
- 1.0.0
License Report
Snapshots
- Configure repository
- Documentation
- Versions

1.0.0