sxnxl / kafka-connect-python
Python module for Kafka Connect REST API
☆14Updated 2 years ago
Alternatives and similar repositories for kafka-connect-python:
Users that are interested in kafka-connect-python are comparing it to the libraries listed below
- ☆70Updated 3 years ago
- Python Rest Client to interact against Schema Registry confluent server☆172Updated this week
- A template repo for building and releasing Airflow provider packages.☆70Updated 9 months ago
- Playground for Lakehouse (Iceberg, Hudi, Spark, Flink, Trino, DBT, Airflow, Kafka, Debezium CDC)☆50Updated last year
- Experiments and demonstrations of AVRO, Protobuf serialisation☆60Updated 2 years ago
- Apache Airflow in Docker Compose (for both versions 1.10.* and 2.*)☆184Updated last year
- A provider package for kafka☆37Updated last year
- The most popular ClickHouse plugin for Airflow. 🔝 Top-1% downloads on PyPI: https://pypi.org/project/airflow-clickhouse-plugin! Based on…☆150Updated 5 months ago
- PostgreSQL CDC library using pgoutput and python☆75Updated 9 months ago
- ☆24Updated 3 years ago
- producer and consumer FastAPI endpoints to handle incoming geo data☆62Updated 4 years ago
- The Python fake data producer for Apache Kafka® is a complete demo app allowing you to quickly produce JSON fake streaming datasets and …☆82Updated 9 months ago
- A repository of sample code to show data quality checking best practices using Airflow.☆74Updated last year
- Fully reproducible, Dockerized, step-by-step, demo on how to stream tables from Postgres to Kafka/KSQL back to Postgres. Detailed blog p…☆152Updated 3 years ago
- ☆50Updated 4 years ago
- Streaming Synthetic Sales Data Generator: Streaming sales data generator for Apache Kafka, written in Python☆42Updated 2 years ago
- Streaming Data from Kafka to Postgres with Kafka Connect, AVRO, Schema Registry and Python☆14Updated 6 years ago
- Repository of helm charts for deploying DataHub on a Kubernetes cluster☆173Updated last week
- ☆49Updated 3 years ago
- Presto Trino with Apache Hive Postgres metastore☆40Updated 5 months ago
- Faust dockerized application☆68Updated 2 years ago
- Generate avro schemas from python dataclasses, Pydantic models and Faust Records. Code generation from avro schemas. Serialize/Deserializ…☆227Updated 2 weeks ago
- Minimal example to run Trino, Minio, and Hive standalone metastore on docker☆49Updated 2 years ago
- Tutorial for setting up a Spark cluster running inside of Docker containers located on different machines☆128Updated 2 years ago
- Airflow Providers containing Deferrable Operators & Sensors from Astronomer☆144Updated this week
- Kafka Connect connector that enables Change Data Capture from JSON/HTTP APIs into Kafka.☆126Updated 6 months ago
- A Helm chart to install Apache Airflow on Kubernetes☆283Updated this week
- Docker Airflow - Contains a docker compose file for Airflow 2.0☆65Updated 2 years ago
- A workspace to experiment with Apache Spark, Livy, and Airflow in a Docker environment.☆39Updated 3 years ago
- Astronomer Core Docker Images☆106Updated 8 months ago