bkatwal / distributed-kafka-consumer-pythonLinks
A distributed Kafka Consumer in Python using Ray
☆24Updated 3 years ago
Alternatives and similar repositories for distributed-kafka-consumer-python
Users that are interested in distributed-kafka-consumer-python are comparing it to the libraries listed below
Sorting:
- Python Rest Client to interact against Schema Registry confluent server☆179Updated 2 months ago
- This library can convert a pydantic class to a avro schema or generate python code from a avro schema.☆82Updated this week
- Generate avro schemas from python dataclasses, Pydantic models and Faust Records. Code generation from avro schemas. Serialize/Deserializ…☆248Updated last month
- Trace FastAPI with Jaeger through OpenTelemetry Python API and SDK.☆106Updated last year
- Implementing an Event Sourcing/CQRS microservices with Apache Kafka☆57Updated last year
- The Prefect API and backend☆250Updated 2 years ago
- Swiple enables you to easily observe, understand, validate and improve the quality of your data☆84Updated this week
- Apache Airflow - OpenApi Client for Python☆444Updated 2 weeks ago
- A Cookiecutter template for creating Faust projects quickly.☆70Updated 3 years ago
- Generate Apache Avro schemas for Python types including standard library data-classes and Pydantic data models.☆46Updated last year
- Ray provider for Apache Airflow☆47Updated 2 years ago
- ☆31Updated 2 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 …☆84Updated last year
- Code examples showing flow deployment to various types of infrastructure☆110Updated 3 years ago
- Using Redis with FastAPI☆122Updated last year
- Python clean architecture and usecase implementation with fastapi and pydiator-core☆155Updated last year
- Faust dockerized application☆68Updated 3 years ago
- Fast iterative local development and testing of Apache Airflow workflows☆204Updated last month
- FasAPI + Prometheus + Grafana!☆216Updated 2 years ago
- Python driver/sqlalchemy/superset connectors☆462Updated this week
- Simple and flexible ML workflow engine☆421Updated 2 years ago
- Fork for Python client for Apache Kafka☆106Updated last year
- How to use the DockerOperator in Airflow within Docker Compose?☆54Updated 4 years ago
- A quick POC for integrating FastAPI and Faust.☆52Updated 5 years ago
- Boilerplate for PySpark on Cloud Kubernetes☆33Updated 4 years ago
- Asyncio-based Python library for working with aiokafka, Confluent Schema Registry, and Kafka Broker APIs.☆24Updated this week
- A repository that makes it easy to get up and running with Prefect 2 using Docker Compose.☆140Updated 9 months ago
- A simple guide to understand Prefect and make it work with your own docker-compose configuration.☆162Updated last year
- A template for a FastAPI based Serverless Framework microservice running on AWS Lambda☆94Updated last year
- A Python RESTful API using FastAPI with a Kafka Consumer☆159Updated 5 years ago