0

在 Spyder 中，我正在尝试 Faust 官方网站上的 Hello World 应用程序：

import faust

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

greetings_topic = app.topic('greetings')

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

我启动 Zookeeper 和 Kafka（kafka 在 Spyder 中使用 Consumer/Producer 示例）

我被困在这个阶段开始一个工人

$ faust -A hello_world worker -l info

我在命令行中尝试过，但$ faust无法识别；我也在 Python 解释器中尝试过，但没有用（我没想到这会起作用）。

我阅读了有关守护进程的信息，所以我想这与此有关，但我可以再次使用 python 解释器运行 Kafka 消费者/生产者示例。

谢谢你

4

0 回答 0