calvinlfer/kafka-zio-integration-leak-reproducer calvinlfer/kafka-zio-integration-leak-reproducer

  • Stars
    star
    1
  • Language
    Scala
  • Created 10 months ago
  • Updated 10 months ago
Twitter logo Share LinkedIn logo Share Facebook logo Share
calvinlfer/kafka-zio-integration-leak-reproducer
github

calvinlfer

Reviews

There are no reviews yet. Be the first to send feedback to the community and the maintainers!

Repository Details

A repository that contains small applications that integrate with FS2 Kafka and ZIO Kafka to determine if there are memory leaks

More Repositories

1

akka-http-streaming-response-examples

A list of examples that involve streaming with Akka Streams and used together with Akka HTTP
Scala
73
star
2

Akka-HTTP-Akka-Streams-Akka-Actors-Integration

Streaming Chuck Norris jokes in JSON as Server Sent Events using Akka Steams, Akka HTTP and Akka Actors
Scala
57
star
3

Akka-Persistence-example-with-Protocol-Buffers-serialization

A simple example that demonstrates the usage of Akka Persistence along with Protocol Buffers as the serialization mechanism
Scala
37
star
4

akka-streams-interleaving

Akka Streams example of how to interleave Sources with priorities
Scala
28
star
5

tagless-final-example

An example of how to create services using tagless final
Scala
25
star
6

es-cqrs-shopping-cart

A resilient and scalable shopping cart system designed using Event Sourcing (ES) and Command Query Responsibility Segregation (CQRS)
Scala
24
star
7

websockets-pubsub-akka

WebSockets and Publish-Subscribe with Akka
Scala
22
star
8

compose-cassandra-cluster

A Docker Compose blueprint describing the creation of a 3 node cluster
19
star
9

free-monads-functional-web-apps

Delving into Free Monads and using them to write pure functional web applications
Scala
17
star
10

Akka-Persistence-Schema-Evolution-Example

This example is intended to demonstrate how to perform Schema Evolution without using an encoding mechanism that supports schema evolution (e.g. Protocol Buffers, Avro and Thrift).
Scala
16
star
11

Kafka-Akka-HTTP-and-Akka-Streams-integration

An example showing how to integrate Apache Kafka with Akka Streams and Akka HTTP.
Scala
15
star
12

Akka-Streams-custom-stream-processing-examples

Demos of how to do custom stream processing using the Akka Streams GraphStages API
Scala
13
star
13

akka-cluster-sample

A sample Akka Cluster application that uses ZooKeeper for service discovery
Scala
13
star
14

skull-island

A tool for 'diffable' Kong API Gateway configuration
JavaScript
13
star
15

akka-cluster-docker-swarm

Deploying a multi-node Akka Cluster to a Docker Swarm
Scala
13
star
16

Play-Framework-Cassandra-Example

An example that shows how you can integrate Cassandra with Play Framework
Scala
7
star
17

Play-Framework-DynamoDB-example

A simplistic Play Framework application providing a REST API for the persons. It makes use of Google Guice injection along with DynamoDB through the use of Scanamo.
Scala
6
star
18

akka-http-streaming-client-and-server

Examples showing how to perform streaming requests and responses using Akka HTTP along with some bonuses
Scala
6
star
19

tyrian-chartjs-interop-example

This is an example of how to use Chart.JS and integrate it with Tyrian
Scala
5
star
20

docker-nexus3-oss

A Sonatype Nexus3 OSS image which makes it easy to do volume mounting
Shell
4
star
21

Akka-persistence-example-with-custom-serializer

Scala
4
star
22

streaming-analytics

A streaming data pipeline to perform basic analytics with scalability in mind
Scala
4
star
23

free-monad-coproduct-example

Free Monad composition using Monad Coproducts from FreeK
Scala
4
star
24

cassandra-ebs-cloudformation

A CloudFormation blueprint to materialize a 3 node Cassandra cluster backed by EBS
3
star
25

alpakka-cassandra-sink-usage

A demonstration of how to use the Alpakka Cassandra Sink to push case classes through to a Cassandra Table
Scala
3
star
26

wallet-api

An implementation of an API for wallet built using Akka (HTTP, Cluster Sharding, Event Sourcing) and ZIO
Scala
3
star
27

rate-limiting-and-gating-akka

An example (from Reactive Design Patterns) that shows how to do rate-limiting and gating on a per-client basis using Akka
Scala
3
star
28

etl-workflow

An opinionated way to structure ETL pipelines with a heavy focus on reusability and testing
Scala
2
star
29

node-aws-examples

Node.JS Examples using the AWS SDK to perform management/other tasks
JavaScript
2
star
30

twitter-streams-example

Playing around with the Play Framework, Iteratees and Akka Streams
Scala
2
star
31

actors-and-streams

Yet another example showing how to use `Sink.actorRef` but with the added twist of using timers
Scala
2
star
32

reactive-s3-sqs-extended-library

The S3 SQS extended library built on Alpakka with configurable delivery semantics
Scala
2
star
33

Weather-Manager

A simple Weather Manager application using Akka HTTP and DynamoDB that interacts with OpenWeather
Scala
2
star
34

ecs-cluster-akka

An AWS CloudFormation template to launch an autoscaling ECS Cluster with an ALB to run Akka apps
1
star
35

scala3-runthrough

Scala
1
star
36

account-experiment

Scala
1
star
37

restify-dynamodb-example

JavaScript
1
star
38

play-framework-validation-example

A minimal example showing how to serialize JSON => Scala and vice versa with additional field validation and tests
Scala
1
star
39

shapeless-guide-runthrough

Scala
1
star
40

sample-node-docker

A sample application showing how to dockerize a Node.JS web application
JavaScript
1
star
41

fill-in-the-blanks

A very simple command line tool that takes opinionated template files and data and generates an output file
JavaScript
1
star