faust

faust copied to clipboard

Error when creating a topic using aiokafka 0.11.0

4

poetry add faust-stream ```py 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...

hgalytoby

Certain topic partitions are not sending fetch requests since initial start

1

## Checklist - [x] I have included information about relevant versions - [ ] I have verified that the issue persists when using the `master` branch of Faust. FWIW I...

Syntaf

Which is the appropriate method for testing timer functions? There are no examples about it in the docs.

giulioindev

## Checklist - [X] I have included information about relevant versions - [X] I have verified that the issue persists when using the `master` branch of Faust. ## Steps to...

dakotahorstman

How to check liveness of agent?

7

We want to implement a liveness check of our Faust application. What is the best gauge of "liveness" of a Faust agent? ## Background The agent is consuming from a...

caspereijkens

Shouldn't StreamT have a filter abstract method?

giulioindev

Question: Throttle Reconnect Attempts when kafka is unavailable

2

## Checklist - [x] I have included information about relevant versions - [x] I have verified that the issue persists when using the `master` branch of Faust. ## Steps to...

jaredvacanti

## Checklist - [x] I have included information about relevant versions - [x] I have verified that the issue persists when using the `master` branch of Faust. ## Steps to...

lubomirmatus

DeprecationWarning: pkg_resources is deprecated as an API

1

## Steps to reproduce create a faust.App instance during testing for the example, there are only 2 files app.py files with a single topic and an event handler and a...

Dimasbka

## Description Adding `on_clear` handlers. Table and GlobalTable share implementation that runs `on_key_del` handler for each key currently stored in the table before cleaning the dictionary. ChangeloggedSet is using existing...

egao1980