faust
faust copied to clipboard
robinhood
Python Stream Processing
Simply requesting to update dependency `click` to support >=8.0 Also python 3.6 has reach EOL on 23 Dec 2021 so one might want to bump that in conda etc. Just...
## 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...
Some strings looks like they're meant to be f-strings but are missing the `f` prefix meaning variable interpolation won't happen. https://github.com/robinhood/faust/blob/01b4c0ad8390221db71751d80001b0fd879291e2/faust/streams.py#L210 I found this issue automatically. I'm a bot. Beep...
## Description Please describe your pull request. Corrected a typo spelling mistake of acknowledged
I am sending camera frames to kafka streams and processing them through a faust agent. the agent process around 10 messages then pauses for a few seconds with a log...
Is it possible to know what is the current offset/lag of the consumer at each partition for a given topic? I'm looking to implement a task queue balancing problem. Is...
Failure handling is an area where there is limited consensus within the Kafka community. One option for Faust would be adding support for failure forwarding in the same pattern as...
## 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...
I have a main agent that runs and collects messages from a kafka topic and a timer that sends one message per hour on another topic. This message triggers a...
