asyncio client for kafka

FastKafka is a powerful and easy-to-use Python library for building asynchronous web services that interact with Kafka topics. Built on top of Pydantic, AIOKafka and AsyncAPI, FastKafka simplifies the process of writing producers and consumers for Kafka topics.

Mockafka-py is a Python library designed for in-memory mocking of Kafka.[aiokafka - confluence-kafka-python]

Fork of aio-libs/aiokafka

Kafka PoC using FastAPI

Asyncio-based Python library for working with aiokafka, Confluent Schema Registry, and Kafka Broker APIs.

Kafka streams processing in Python.

RPC over Apache Kafka for Python using asyncio

Package to make compatible aiokafka with open telemetry

A FastAPI-inspired framework to build production-grade Kafka applications effortlessly, with support for routing, DI, retries, DLQ, and custom serialization.

No description available

Websocket Server/reader for the Kafka Protocol (aiokafka -> aiohttp)

Simple "Hello World" using aiokafka and websockets

Simple wrapper for the AIOKafka library using pydantic configuration parsing

Payment Service is a microservice for handling payments, managing invoices and transactions, and integrating with multiple external payment providers in the Microshop project.

Order Service is a microservice responsible for managing orders in the Microshop project.

No description available

asyncio client for kafka - HARD FORK from aio-libs/aiokafka

Group consumer using AIO Python Kafka client on a Tansu topic backed by S3

Kafkify is a lightweight, opinionated wrapper around aiokafka

poetry add "uvicorn[standard]" "python-jose[cryptography]" poetry add sqlmodel poetry add "psycopg[binary]" poetry add python-multipart poetry add email-validator poetry add passlib[bcrypt] poetry add tenacity pydantic emails poetry add aiokafka

Example of working with kafka clients in python

This demo solution uses Kafka, Clickhouse and presents two services written on Python3: price-generator and price-monitor. The first one generates an array of 52 items of random trade data every millisecond and writes it to Kafka. The second consumes hot data from Kafka and with minimal latency sends a notification when a trade condition occurs.

This project simulates a real-time trade streaming platform using Kafka and Python's async features (aiokafka). It demonstrates how to build a modular, observable, and fault-tolerant system for delivering trade events to risk engines or back-office processors.

A conda-smithy repository for aiokafka.

No description available

aiokafka manager service for kafka producer/consumer connections using aiokafka and asyncio

Debian packaging for aiokafka module

No description available

RPM packaging for aiokafka