faust

faust copied to clipboard

Unable to terminate faust worker programatically

3

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

hlacikd

New error messages seen in faust app with aiokafka 0.7.1

30

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

patkivikram

Crash and duplicated events on rebalance with processing_guarantee="exactly_once"

3

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

sauerburger

Leader election without a timer

1

Based on the documentation, it seems that Faust only supports leader election for periodic agents. I understand that the `concurrency` keyword argument to `app.agent` can be used to specify the...

hdhillan

Producers slow to send new messages after idle period, consumers slow to read new messages after idle period

9

## Steps to reproduce I have a pipeline where a message is produced to topic A, which is processed by a stream processor and sends enriched data to topic B....

fonty422

Event runtime metric is zero when using `stream.take(...)`

2

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

derkach-ip

Prometheus histogram buckets are in seconds, but values are milliseconds

1

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

vilozio

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

ostetsenko

Custom headers are not handled properly when self.error is used in web views

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

popadi

stream.events() vs stream.noack().noack_take(1,1)

2

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

ekerstens