jaspervz / akkastreams-kafka-example
An example project using Akka Streams with Kafka and a Schema Registry to read and write messages in Avro format.
☆16Updated 4 years ago
Related projects ⓘ
Alternatives and complementary repositories for akkastreams-kafka-example
- Microservice blueprint using Akka-Http, Circe JSON, Cassandra, Specs2☆36Updated 8 years ago
- Akka Projections is intended for building systems with the CQRS pattern, and facilitate in event-based service-to-service communication.☆102Updated last week
- Purely functional Apache Pulsar client for Scala built on top of Fs2☆71Updated last week
- Sample code for the Akka Typed blog series☆50Updated 6 years ago
- Example of Akka HTTP server compiled with GraalVM native-image☆93Updated 5 years ago
- Play + Pekko gRPC☆35Updated last week
- Example showing how to create an Akka Cluster on Kubernetes.☆45Updated 7 months ago
- A Scala library for creating Swagger definitions in a type-safe fashion wth Akka-Http☆73Updated 5 years ago
- Companion repo for Lightbend blog post - How To Distribute Application State with Akka Cluster☆46Updated last month
- Build highly concurrent, distributed, and resilient message-driven applications on the JVM☆45Updated 2 years ago
- Functional DevOps with Scala and Kubernetes☆102Updated 5 years ago
- Terminal UI observability and diagnostic tool for Scala applications☆106Updated 2 years ago
- Functional programming with Kafka and Scala☆92Updated this week
- Akka HTTP REST API Project Template using Akka HTTP 10.0.4 with Circe 0.7.0 targeting Scala 2.12.x☆20Updated 7 years ago
- Kafka client for functional streams for scala (fs2)☆78Updated last year
- ☆47Updated 3 years ago
- Realtime feedback of Akka Stream processing via WebSockets☆16Updated 4 years ago
- Quorum split brain resolver for static akka cluster☆96Updated 4 years ago
- Implicit conversion of Encoder and Decoder into Serializer/Deserializer/Serde☆25Updated this week
- Command-line based ticket system written in Scala 3☆57Updated 3 years ago
- Functional Avro for Scala☆102Updated this week
- Read/Write Scala objects directly to Protobuf with no .proto file definitions☆97Updated 4 years ago
- Keycloak4s is a Scala client for the Keycloak Admin API☆66Updated 2 months ago
- ☆44Updated 4 years ago
- Kinesis Client Library Akka Stream☆32Updated 3 months ago
- PoC using scala that defines single-message protobuf schema per Kafka topic☆23Updated 4 years ago
- OpenTelemetry agent for Scala applications☆71Updated this week
- An example of a microservice template which uses akka/reactive-kafka to stream JSON messages☆84Updated 7 years ago
- Principled, fast, typeclass derivation.☆52Updated this week
- Apache Pekko Kafka Connector - Pekko-Connectors is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Stream…☆22Updated this week