hello_world.py

import faust

app = faust.App("hello-world", broker="kafka://localhost:9092", value_serializer="raw",)

greetings_topic = app.topic("first-topic")


@app.agent(greetings_topic)
async def greet(greetings):
    async for greeting in greetings:
        print(greeting)