rh-marketingops / fluviiLinks
A kafka streams client library built on confluent-kafka-python
☆66Updated 2 years ago
Alternatives and similar repositories for fluvii
Users that are interested in fluvii are comparing it to the libraries listed below
Sorting:
- Python Rest Client to interact against Schema Registry confluent server☆179Updated last week
- Generate avro schemas from python dataclasses, Pydantic models and Faust Records. Code generation from avro schemas. Serialize/Deserializ…☆244Updated last week
- PostgreSQL CDC library using pgoutput and python☆79Updated last year
- This library can convert a pydantic class to a avro schema or generate python code from a avro schema.☆79Updated 3 weeks ago
- Library/micro framework to create streaming applications with kafka in a fast way☆39Updated last week
- Python AsyncIO Services☆48Updated 3 months ago
- Python data types for the Apache Kafka® Protocol.☆24Updated last month
- Distributed event processing for Python based on Redis Streams☆135Updated 5 years ago
- Fork for Python client for Apache Kafka☆105Updated last year
- A Cookiecutter template for creating Faust projects quickly.☆70Updated 2 years ago
- A python wrapper for the KSQL REST API.☆158Updated 2 years ago
- Restate SDK for Python☆46Updated 2 weeks ago
- Stateful streaming computations implemented with many technologies☆31Updated last year
- ☆80Updated 6 months ago
- MongoDB integrations for Apache Arrow. Export MongoDB documents to numpy array, parquet files, and pandas dataframes in one line of code.☆111Updated last week
- ☆70Updated 10 months ago
- ☆30Updated 11 months ago
- Apache DataFusion Python Bindings☆516Updated last week
- Python client for Trino☆402Updated 2 months ago
- Multi-hop declarative data pipelines☆122Updated last week
- Python bindings for sqlparser-rs☆198Updated 5 months ago
- CLI tool to bulk migrate the tables from one catalog another without a data copy☆83Updated 6 months ago
- A dbt adapter for Decodable☆12Updated 2 months ago
- A quick POC for integrating FastAPI and Faust.☆51Updated 4 years ago
- A portable Multimodal Lakehouse powered by Ray that brings exabyte-level scalability and fast, ACID-compliant, change-data-capture to you…☆247Updated 3 weeks ago
- Column-wise type annotations for pyspark DataFrames☆89Updated last week
- 🧘♀️ Lightweight fault tolerant primitives for your modern asyncio Python microservices☆88Updated last year
- A one-afternoon implementation of redis-like primitives with S3 Express☆33Updated last year
- Samples for working with the Temporal Python SDK☆265Updated last week
- 📦 Autowiring dependency injection container for python 3☆330Updated 3 months ago