Alternatives and similar repositories for kafka-aggregator

Users that are interested in kafka-aggregator are comparing it to the libraries listed below

• marcosschroh / cookiecutter-faust
  A Cookiecutter template for creating Faust projects quickly.
  ☆70Updated 2 years ago
• marcosschroh / faust-docker-compose-example
  Faust dockerized application
  ☆68Updated 2 years ago
• RedisTimeSeries / redistimeseries-py
  RedisTimeSeries python client
  ☆99Updated 2 years ago
• godatadriven / pydantic-avro
  This library can convert a pydantic class to a avro schema or generate python code from a avro schema.
  ☆74Updated last week
• Drakkar-Software / Async-Channel
  Python async multi-task communication library. Used by OctoBot project.
  ☆23Updated last year
• jpmorganchase / py-avro-schema
  Generate Apache Avro schemas for Python types including standard library data-classes and Pydantic data models.
  ☆42Updated 9 months ago
• marcosschroh / dataclasses-avroschema
  Generate avro schemas from python dataclasses, Pydantic models and Faust Records. Code generation from avro schemas. Serialize/Deserializ…
  ☆233Updated this week
• marcosschroh / python-schema-registry-client
  Python Rest Client to interact against Schema Registry confluent server
  ☆176Updated this week
• robinhood / airflow-prometheus-exporter
  Prometheus Exporter for Airflow
  ☆160Updated 11 months ago
• ipeluffo / faust-hashtags-counter
  Sample Faust project to process tweets in real-time
  ☆13Updated 4 years ago
• dirkjonker / sqlalchemy-turbodbc
  SQLAlchemy dialect for Turbodbc
  ☆23Updated last month
• sphinx-contrib / prefectviz
  An extension to add Prefect flow visualizations into you Sphinx documentation.
  ☆13Updated 3 years ago
• QuantConnect / AlphaStreams
  Alpha Streams Public SDK.
  ☆12Updated last year
• transferwise / pipelinewise-target-snowflake
  Singer.io Target for Snowflake - PipelineWise compatible
  ☆51Updated 8 months ago
• BasPH / pylint-airflow
  Pylint plugin for static code analysis on Airflow code
  ☆95Updated 4 years ago
• notsambeck / pandabase
  pandabase links DataFrames to SQL databases using primary keys.
  ☆21Updated 4 years ago
• sasha-tkachev / fastapi-cloudevents
  CloudEvents FastAPI plugin. Allows to easily consume and produce events in CloudEvents format over REST API.
  ☆35Updated last year
• googleapis / python-iam
  This library has moved to https://github.com/googleapis/google-cloud-python/tree/main/packages/google-cloud-iam
  ☆37Updated last year
• PolideaInternal / airflow-breeze-gcp-extension
  ☆24Updated 5 years ago
• 1kbgz / greeks
  Derivatives models written with the Tributary data flow library
  ☆23Updated last month
• schlerp / picoapi
  An opinionated wrapper around FastAPI with custom microservice registration
  ☆53Updated 3 years ago
• erdewit / eventkit
  Event-driven data pipelines
  ☆141Updated last year
• faust-streaming / mode
  Python AsyncIO Services
  ☆47Updated last year
• fugue-project / triad
  A collection of python utility functions
  ☆11Updated 11 months ago
• robinhood / kafka-python
  Python client for Apache Kafka
  ☆6Updated last year
• ludwigm / prefect-demo-flow
  This is the code accompanying the blog article on makeitnew.io. It defines a Prefect flow which can be visualized, run locally or registe…
  ☆29Updated 4 years ago
• vinish-ai / polars-streaming
  Stream Processing using Polars
  ☆30Updated 2 years ago
• wemake-services / wemake-dind
  Our docker-in-docker image with Python
  ☆16Updated this week
• bytehub-ai / bytehub
  ByteHub: making feature stores simple
  ☆60Updated 4 years ago
• justindujardin / pathy
  simple, flexible, offline capable, cloud storage with a Python path-like interface
  ☆173Updated last month