decodableco / decodable-pipeline-sdkLinks
An SDK for implementing Flink jobs based on Decodable
โ13Updated 3 weeks ago
Alternatives and similar repositories for decodable-pipeline-sdk
Users that are interested in decodable-pipeline-sdk are comparing it to the libraries listed below
Sorting:
- ๐ Examples of use cases that utilize Decodable, as well as demos for related open-source projects such as Apache Flink, Debezium, and Poโฆโ87Updated 6 months ago
- Collection of utilities to allow writing java code that operates across a wide range of avro versions.โ86Updated last month
- This project contains a couple of tools to analyze data around the Apache Flink community.โ18Updated last year
- Port of TPC-H dbgen to Javaโ52Updated last year
- Serializable ACID transactions on streaming dataโ25Updated 3 years ago
- A collection of examples of Kafka Streams being used in production. Contributions welcome!โ47Updated 9 months ago
- Examples for using Apache Flinkยฎ with DataStream API, Table API, Flink SQL and connectors such as MySQL, JDBC, CDC, Kafka.โ65Updated 2 years ago
- Example of a tested Apache Flink application.โ43Updated 6 years ago
- Ecosystem website for Apache Flinkโ12Updated last year
- Lab project to showcase Flink's performance differences between using a SQL query and implementing the same logic via the DataStream APIโ14Updated 5 years ago
- Stream Discovery and Stream Orchestrationโ122Updated last week
- โ66Updated last year
- โ34Updated 2 months ago
- โ49Updated 3 years ago
- A library for strong, schema based conversion between 'natural' JSON documents and Avroโ18Updated last year
- โ29Updated 4 years ago
- An example of using Flink for Fault-Tolerant Stream Processingโ12Updated 7 years ago
- Spark Connector to read and write with Pulsarโ116Updated last week
- Utility project for working with Kafka Connect.โ34Updated last year
- Utility functions and base classes for Kafka Streams applicationsโ35Updated this week
- li-apache-kafka-clients is a wrapper library for the Apache Kafka vanilla clients. It provides additional features such as large message โฆโ135Updated 2 years ago
- Aiven's JDBC Sink and Source Connectors for Apache Kafkaยฎโ111Updated 3 months ago
- Example setup to demonstrate Prometheus integration of Apache Flinkโ94Updated last week
- Lab for testing different Flink job latency optimization techniques covered in a Flink Forward 2021 talkโ27Updated 4 years ago
- Pinterest's simplified and efficient Tiered Storage implementation for Kafkaโ23Updated this week
- A list of all awesome open-source contributions for the Apache Kafka projectโ108Updated 2 years ago
- Kafka Connect FileSystem Connectorโ112Updated 3 years ago
- A repository containing materials for Stateful Functions workshopโ45Updated 2 years ago
- LinkedIn's version of Apache Calciteโ24Updated 6 months ago
- Fast Apache Avro serialization/deserialization libraryโ45Updated this week