rh-marketingops / fluvii
A kafka streams client library built on confluent-kafka-python
☆67Updated 11 months ago
Related projects: ⓘ
- Python Rest Client to interact against Schema Registry confluent server☆169Updated this week
- Generate avro schemas from python classes. Code generation from avro schemas. Serialize/Deserialize python instances with avro schemas☆213Updated this week
- PostgreSQL CDC library using pgoutput and python☆72Updated 4 months ago
- This library can convert a pydantic class to a avro schema or generate python code from a avro schema.☆60Updated last week
- Python AsyncIO Services☆42Updated 5 months ago
- Distributed event processing for Python based on Redis Streams☆133Updated 4 years ago
- A python wrapper for the KSQL REST API.☆159Updated last year
- ☆28Updated this week
- A Cookiecutter template for creating Faust projects quickly.☆70Updated last year
- Swiple enables you to easily observe, understand, validate and improve the quality of your data☆79Updated this week
- Fork for Python client for Apache Kafka☆66Updated last month
- Library/micro framework to create streaming applications with kafka in a fast way☆34Updated 2 weeks ago
- Asyncio-based Python library for working with aiokafka, Confluent Schema Registry, and Kafka Broker APIs.☆21Updated this week
- Python bindings for sqlparser-rs☆152Updated last week
- Faust dockerized application☆68Updated last year
- 🧘♀️ Lightweight fault tolerant primitives for your modern asyncio Python microservices☆72Updated 9 months ago
- Stateful streaming computations implemented with many technologies☆31Updated 4 months ago
- A high-performance Python Kafka client. Efficiently from Kafka to Pandas and back.☆39Updated 5 years ago
- Implement the Health Check API pattern on your FastAPI application!☆174Updated last year
- ☆77Updated last year
- SQLAlchemy driver for DuckDB☆336Updated last week
- ✨ A Pydantic to PySpark schema library☆53Updated this week
- ⚡A supercharged, interactive Kafka shell built on top of the existing Kafka CLI tools.☆123Updated 4 years ago
- A simple Python-based distributed workflow engine☆53Updated 2 weeks ago
- Fast iterative local development and testing of Apache Airflow workflows☆192Updated 3 months ago
- Stream Processing Made Easy☆38Updated 2 years ago
- Opionated helpers for creating py.test fixtures for Docker integration and smoke testing environments☆83Updated last month
- Example Polylith setup for Python☆48Updated 2 weeks ago
- fast data loading with binary copy☆112Updated 4 months ago
- Prometheus middleware for Starlette and FastAPI☆38Updated 3 years ago