mrooding / flink-avro-state-serialization
☆9Updated 5 years ago
Related projects ⓘ
Alternatives and complementary repositories for flink-avro-state-serialization
- ☆35Updated 2 years ago
- Sbt plugin for avro4s☆20Updated 6 years ago
- Deriving Spark DataFrame schemas from case classes☆44Updated 4 months ago
- Writing application logic for Spark jobs that can be unit-tested without a SparkContext☆76Updated 5 years ago
- Generic Serdes with Circe for Kafka Streams☆28Updated 2 years ago
- ☆44Updated 4 years ago
- ☆18Updated 3 years ago
- Sample code for the Akka Typed blog series☆50Updated 6 years ago
- Lego bricks to build Apache Kafka serializers and deserializers☆119Updated last year
- Implicit conversion of Encoder and Decoder into Serializer/Deserializer/Serde☆25Updated last week
- Optics for Spark DataFrames☆47Updated 3 years ago
- Activator template for Reactive Kafka☆20Updated 7 years ago
- Use GRPC services with the Akka-stream API☆69Updated 5 years ago
- Realtime feedback of Akka Stream processing via WebSockets☆16Updated 4 years ago
- Reactive Payment Processor example from the Tour of Akka Cluster article series☆29Updated 6 years ago
- Study on akka-serialization using ProtoBuf, Kryo and Avro☆31Updated 8 years ago
- Plugin SBT to Generate Scala classes from Apache Avro schemas hosted on a remote Confluent Schema Registry.☆15Updated 6 years ago
- ☆47Updated 3 years ago
- Scala + Druid: Scruid. A library that allows you to compose queries in Scala, and parse the result back into typesafe classes.☆115Updated 3 years ago
- Simple SBT plugin to configure Spark applications☆24Updated 3 months ago
- ☆50Updated 4 years ago
- Implicitly converts typeclass encoders to kafka Serializer, Deserializer, Serde.☆57Updated 3 months ago
- Evaluation of Play 2.8 API and performance using wrk2☆19Updated 4 years ago
- Throughput and latency monitoring for Akka Streams☆25Updated 6 years ago
- Discover java object sizes through questionable sleuthing plus luck.☆67Updated 6 years ago
- Import data from CSV files to Cassandra using Monix Reactive Streams☆12Updated 6 years ago
- Akka Streams connectors for Kinesis☆14Updated 4 years ago
- Scala toolchain for InfluxDB☆27Updated 3 months ago
- A fork of Apache Flink scala bindings for 2.12, 2.13 and 3.x☆20Updated 3 months ago