decodableco / decodable-pipeline-sdkLinks
An SDK for implementing Flink jobs based on Decodable
☆13Updated 3 months 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…☆85Updated 5 months ago
- Collection of utilities to allow writing java code that operates across a wide range of avro versions.☆85Updated 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
- Examples for using Apache Flink® with DataStream API, Table API, Flink SQL and connectors such as MySQL, JDBC, CDC, Kafka.☆65Updated 2 years ago
- Ecosystem website for Apache Flink☆12Updated last year
- Apache flink☆18Updated 2 years ago
- 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
- Graph Analytics with Apache Kafka☆106Updated 3 weeks ago
- Apache iceberg Spark s3 examples☆20Updated last year
- ☆29Updated 3 years ago
- Apache Kafka is an open-source distributed event streaming platform used by thousands of companies. uForwarder aims to address several pa…☆94Updated last month
- Example setup to demonstrate Prometheus integration of Apache Flink☆94Updated this week
- Kafka Interceptor for Zipkin☆35Updated 3 years ago
- Fast Apache Avro serialization/deserialization library☆45Updated 5 years ago
- Utility functions and base classes for Kafka Streams applications☆34Updated this week
- An In-Memory Cache Backed by Apache Kafka☆256Updated last month
- A collection of examples of Kafka Streams being used in production. Contributions welcome!☆45Updated 8 months ago
- Generate and Compare Debezium CDC (Chance Data Capture) Avro Schema, directly from your Database.☆22Updated last month
- Fork of Apache Kafka implementing KIP-1150 -- Diskless Topics☆71Updated last week
- A library for strong, schema based conversion between 'natural' JSON documents and Avro☆18Updated last year
- kafka-connect-jdbc system test based on testcontainers☆13Updated 2 years ago
- Spring Data Module for YugabyteDB.☆18Updated 4 years ago
- Example of a tested Apache Flink application.☆43Updated 6 years ago
- Spark Connector to read and write with Pulsar☆116Updated 2 months ago
- 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
- Multi-hop declarative data pipelines☆122Updated 2 weeks ago
- Demonstration of a Hive Input Format for Iceberg☆26Updated 4 years ago
- An example of using Flink for Fault-Tolerant Stream Processing☆12Updated 6 years ago
- ☆34Updated last month