Faust пример публикации в теме кафки - PullRequest
Новая
       32

Faust пример публикации в теме кафки

0 голосов
/ 27 июня 2019

Мне любопытно, как вы должны выразить, что хотите, чтобы сообщение было доставлено в тему Кафки в faust. Пример в их readme, похоже, не пишет в тему: 

import faust

class Greeting(faust.Record):
    from_name: str
    to_name: str

app = faust.App('hello-app', broker='kafka://localhost')
topic = app.topic('hello-topic', value_type=Greeting)

@app.agent(topic)
async def hello(greetings):
    async for greeting in greetings:
        print(f'Hello from {greeting.from_name} to {greeting.to_name}')

@app.timer(interval=1.0)
async def example_sender(app):
    await hello.send(
        value=Greeting(from_name='Faust', to_name='you'),
    )

if __name__ == '__main__':
    app.main()

Я бы ожидал, что hello.send в приведенном выше коде опубликует сообщение в теме, но оно не отображается.

Существует множество примеров чтения по темам, а также множество примеров использования клика для отправки специального сообщения. После просмотра документов я не вижу четких примеров публикации тем в коде. Я просто схожу с ума, и приведенный выше код должен работать?

...