ikucan / pykafarr
A high-performance Python Kafka client. Efficiently from Kafka to Pandas and back.
☆40Updated 5 years ago
Alternatives and similar repositories for pykafarr:
Users that are interested in pykafarr are comparing it to the libraries listed below
- A Cookiecutter template for creating Faust projects quickly.☆70Updated 2 years ago
- Derivatives models written with the Tributary data flow library☆23Updated 2 months ago
- Python Rest Client to interact against Schema Registry confluent server☆172Updated this week
- Deploy dask on YARN clusters☆69Updated 6 months ago
- A perspective powered, user editable ray dashboard via ray serve.☆41Updated this week
- Python driver for Timeplus Enterprise or Timeplus Proton☆14Updated 2 months ago
- A kafka streams client library built on confluent-kafka-python☆67Updated last year
- Rayvens makes it possible for data scientists to access hundreds of data services within Ray with little effort.☆49Updated 2 years ago
- Stream Processing Made Easy☆39Updated 2 years ago
- RedisTimeSeries python client☆99Updated 2 years ago
- A python wrapper for the KSQL REST API.☆159Updated last year
- Native Kubernetes integration for Dask☆318Updated 2 weeks ago
- Distributed event processing for Python based on Redis Streams☆133Updated 4 years ago
- Pandas ExtensionDType/Array backed by Apache Arrow☆229Updated last year
- Function dependencies resolution and execution☆71Updated 4 years ago
- A consistent table management library in python☆160Updated last year
- A tool and library for easily deploying applications on Apache YARN☆142Updated 11 months ago
- A library on top of either pex or conda-pack to make your Python code easily available on a cluster☆45Updated 2 months ago
- A Python implementation of Apache Kafka Streams☆311Updated 6 years ago
- Arrow, pydantic style☆84Updated 2 years ago
- Generate avro schemas from python dataclasses, Pydantic models and Faust Records. Code generation from avro schemas. Serialize/Deserializ…☆226Updated last week
- Deploy your Spark Production Cluster on Kubernetes☆47Updated 4 years ago
- Python DataFrame with fast insert and appends☆75Updated last year
- Vinum is a SQL processor for Python, designed for data analysis workflows and in-memory analytics.☆65Updated 3 years ago
- Cloud provider cluster managers for Dask. Supports AWS, Google Cloud Azure and more...☆138Updated 3 weeks ago
- SQL on dataframes - pandas and dask☆64Updated 6 years ago
- Distributed SQL Engine in Python using Dask☆401Updated 5 months ago
- Python binding for DataFusion☆59Updated 2 years ago
- Python stream processing for analytics☆31Updated this week
- Fork of aio-libs/aiokafka☆27Updated last year