"""Use Faust to read data."""
import faust

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

test_topic = app.topic('topic_test')

@app.agent(test_topic)
async def greet(counters):
    async for counter in counters:
        print(counter)