DivLoic / xke-ratatouille
Poison pills and Kafka Streams demo
☆10Updated 4 years ago
Alternatives and similar repositories for xke-ratatouille:
Users that are interested in xke-ratatouille are comparing it to the libraries listed below
- Kafka Streams demo project containing Derivative Events, the Processor Api and Wall-clock examples☆26Updated 4 years ago
- A library that provides in-memory instances of both Kafka and Confluent Schema Registry to run your tests against.☆116Updated last month
- ☆36Updated 2 years ago
- type-class based data cleansing library for Apache Spark SQL☆78Updated 5 years ago
- Code snippets used in demos recorded for the blog.☆33Updated this week
- Lego bricks to build Apache Kafka serializers and deserializers☆120Updated last year
- Library offering http based query on top of Kafka Streams Interactive Queries☆69Updated 2 years ago
- Writing an Avro file is not as fast as you might want it. This is a library to write considerably faster to an avro file.☆33Updated 7 years ago
- ☆9Updated 5 years ago
- ☆45Updated 4 years ago
- Nested array transformation helper extensions for Apache Spark☆37Updated last year
- Sample processing code using Spark 2.1+ and Scala☆51Updated 4 years ago
- A dynamic data completeness and accuracy library at enterprise scale for Apache Spark☆30Updated 5 months ago
- ☆26Updated 3 years ago
- Optics for Spark DataFrames☆47Updated 4 years ago
- Realtime feedback of Akka Stream processing via WebSockets☆16Updated 5 years ago
- Java Application to automate adding Kafka ACLs & Kafka Topics (works with Confluent Platform & Confluent Cloud)☆35Updated 3 years ago
- Circus Train is a dataset replication tool that copies Hive tables between clusters and clouds.☆88Updated last year
- Examples of Avro, Kafka, Schema Registry, Kafka Streams, Interactive Queries, KSQL, Kafka Connect in Scala☆63Updated 8 months ago
- A library to support building a coherent set of flink jobs☆17Updated 6 months ago
- Scala ADT support for Apache Flink☆52Updated 8 months ago
- Functional programming with Kafka and Scala☆95Updated this week
- Flink Scala API is a thin wrapper on top of Flink Java API which support Scala Types for serialisation as well the latest Scala version☆86Updated this week
- Fluent Kafka Streams Test with Java☆89Updated last week
- A tool to validate data, built around Apache Spark.☆101Updated 3 weeks ago
- A fork of Apache Flink scala bindings for 2.12, 2.13 and 3.x☆21Updated 8 months ago
- Flowchart for debugging Spark applications☆105Updated 6 months ago
- Implicitly converts typeclass encoders to kafka Serializer, Deserializer, Serde.☆58Updated 2 months ago
- ☆34Updated 3 years ago
- TestKit - Embedded Kafka, Zookeeper, Schema Registry☆10Updated 7 years ago