FilesExpand file tree

 master

/

faust_helloworld.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

11 lines (7 loc) · 263 Bytes

 master

/

faust_helloworld.py

Copy path

Top

File metadata and controls

• Code
• Blame

11 lines (7 loc) · 263 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

import faust

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

greetings_topic = app.topic("greetings")

@app.agent(greetings_topic)

async def greet(greetings):

async for greeting in greetings:

print(greeting)