evkafka 0.3.0

EVKafka framework. Handle kafka events easy

evkafka

EVKafka is a small framework for building event driven microservices with Apache Kafka and Python.

Installation

 $ pip install evkafka

Basic consumer

from evkafka import EVKafkaApp


config = {
    "topics": ["topic"],
    "bootstrap_servers": "kafka:9092",
    "group_id": "test",
}

app = EVKafkaApp(config=config)


@app.event("FooEvent")
async def foo_handler(event: dict) -> None:
    print(event)


if __name__ == "__main__":
    app.run()

Basic producer

import asyncio
from evkafka import EVKafkaProducer


async def produce(event: dict, event_type: str):
    config = {
        "topic": "topic", 
        "bootstrap_servers": "kafka:9092"
    }

    async with EVKafkaProducer(config) as producer:
        await producer.send_event(
            event=event,
            event_type=event_type,
        )

if __name__ == "__main__":
    asyncio.run(produce({"data": "value"}, "FooEvent"))

More details can be found in the documentation

Status

The framework is in alpha.

License

This project is licensed under the terms of the MIT license.