faust
faust copied to clipboard
robinhood
Python Stream Processing
## 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...
## Steps to reproduce use stream.take and watch the app.monitor events_active counter. ``` #!/usr/bin/env python3 import random import ssl import faust def main_loop(): app = get_faust() topic = app.topic( 'test-topic-stream-take',...
*Note*: Before submitting this pull request, please review our [contributing guidelines](https://faust.readthedocs.io/en/master/contributing.html). ## Description specifying language used on code blocks NOTE: All patches should be made against master, not a maintenance...
There are small typos in: - examples/django/proj/settings.py - faust/transport/drivers/aiokafka.py - faust/types/settings/params.py - faust/types/settings/settings.py Fixes: - Should read `ridiculously` rather than `ridiculuously`. - Should read `environment` rather than `environent`. - Should...
We try to connect to a kerberized Kafka Cluster. In Java we use a keytab to achieve that, the JAAS File looks like this, we use SASL_SSL and GSSAPI: KafkaClient...
## 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...
As the title says, I want to do something like below.. But currently the sink_topic in kafka will have `null` as `key` and whatever that is yielded is treated as...
The last commit in the master was [on 9 Oct 2020](https://github.com/robinhood/faust/commit/01b4c0ad8390221db71751d80001b0fd879291e2). Is the project supported? What are the plans? What are the reasons?
