pekko

Message Acknowledgement for Pekko Streams

Generic components for building services

Scala CDC worker with transactional checkpoints, crash recovery, Debezium events and Kafka integration

A theater for Pekko actors, dispatches, routers, and mailboxes.

Part of the Document Library micro service ecosystem. Co-ordinates all the consumer micro services.

Part of the Document Library micro service ecosystem. Uncompresses files that have been archived using zip, tar, gzip, 7zip & more

Part of the Document Library micro service ecosystem. Converts spreadsheets to text.

Actor-based game server framework for 4X-SLG games, built on Apache Pekko Typed with Master/Slave architecture, AOI vision system, and cross-server RPC.

A comprehensive RESTful API built with Play Framework and Scala demonstrating clean architecture patterns, dependency injection, asynchronous programming, Futures-based concurrency, and the Actor model.

Scala wrapper for the Pekko Connectors MQTT Streaming library and the Alpakka MQTT Streaming library.

Specialist Claude Code agents for the Scala ecosystem — ZIO, Pekko, Cats Effect, build tools, codecs, HTTP, databases, and testing.

Mock WS Standalone client for Play Framework

Small Pekko Projects for learning pekko

Type-safe HTTP for Kotlin on Pekko HTTP. Describe an endpoint once, with its declared failures, and get the route, the OpenAPI document, typed clients and MCP tools from it.

Java samples with different tech & libs.

Multiplayer turn-based game server built on Pekko typed actors, with a pluggable architecture for adding new game types. Real-time play over JWT-authenticated WebSockets and REST APIs (Pekko HTTP), a Redis pub/sub event stream folded into Prometheus metrics, and persistent state in PostgreSQL via Doobie with a Redis write-through cache.

Architecture spike: operating a 1–10M device fleet on a live map. Scala 3 + Pekko HTTP vs Go + Echo over identical Dapr, PostGIS, ClickHouse infrastructure, with a k6 load-test harness.

Arrow's fx combinators on virtual threads instead of coroutines: drop the suspend and the body stays the same. Also applications as checked graphs, streams, actors and clusters.

IoT telemetry pipeline in Scala 3 and Pekko, benchmarked against its Erlang/OTP twin. MQTT, multiple databases, Prometheus and Grafana.