faust

faust copied to clipboard

Windows lost during/after a worker dies or is re-balanced

7

## Steps to reproduce Run the [windowed_aggreagation](https://github.com/faust-streaming/faust/blob/master/examples/windowed_aggregation.py) example on 2 workers. Kill one worker and observe the output. ## Expected behavior After a re balance (or similar disruption) all old...

fonty422

Unable to subscribe to topics by pattern

4

## Steps to reproduce Created a topic specifying pattern= with a valid regex that should have matched multiple topics on the kafka cluster. Running the worker with `-l info` shows...

xgamer4

QUESTION: Any possibility of getting a sliding window example

10

I note in the docs that it states you support hoping, tumbling, and sliding windows. There's even a `faust.SlidingWindow` class, but I can't seem to figure how to implement it....

fonty422

[^---AIOKafkaConsumerThread]: Thread keepalive is not responding ERROR

4

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

informatica92

Problems with offset commits with filter/group_by pattern

2

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

remy-sl

Rebalance can leave some workers with no partitions

5

## 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...

bobh66

Is it possible to use table_route to join windowed results across workers

1

Question I noted that with the word_count example, that the count table can be recalculated on a re-balance (using the @app.table_route option with the @app.page option). But is it possible...

fonty422

## Steps to reproduce Create faust record with field of type Set. Serialize and deserialize using json serializer (works with the default serializer). The resulting record has the field of...

matejlogar

Need zstd compression support while consuming/producing

8

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

akgoel-mo

Thanks for picking up this repo from the dead. While we're at it - does it make sense to also add support for other KV stores besides rocksdb? The project...

dbischof90