faust

faust copied to clipboard

Fix disabled aiokafka unit tests

1

It's going to be hard to investigate what's going on with https://github.com/faust-streaming/faust/issues/175 unless we get better testing in place.

wbarnha

Does Faust Streaming Consumer retry the offset commit if it fails?

1

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

arcanjo45

Message isn't published although logs say it was sent

1

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

eblis

Union of types is not supported

4

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

xcarlosamm

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

vitalbbyy

Events getting skipped

1

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

VatsalLalcheta

## Steps to reproduce app = App(topic_name, broker) app.conf.consumer_auto_offset_reset = "latest" # earliest latest app.conf.broker_heartbeat_interval = 60 topic = app.topic(topic_name) Appears approximately one day after starting Faust Timer Recovery.stats woke...

Abraham-liuhai

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

arcanjo45

`SetTable`s are missing `on_clear`

1

`mode` has a method to clear all the elements in a set (https://github.com/faust-streaming/mode/blob/c0aa58181432402dca30aa5978179383863a185a/mode/utils/collections.py#L546-L548) which calls an `.on_clear` callback. This `.on_clear` callback method is empty by default (https://github.com/faust-streaming/mode/blob/c0aa58181432402dca30aa5978179383863a185a/mode/utils/collections.py#L535-L536) However, `faust` does...

cristianmatache

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

cristianmatache