faust

faust copied to clipboard

When the service is redeployed, resulting in data loss

2

When the service is redeployed, the kafka data is consumed, but it does not fall into the database, resulting in data loss

changtingQ

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

Consumer works for sometime with Kafka on Azure Event Hub and dies after couple of days or week.

5

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

keerthij

processing_guarantee="exactly_once" crashes at startup

2

## Steps to reproduce Create a simple app with `processing_guarantee="exactly_once"` ```py import faust from faust.types import ProcessingGuarantee class Content(faust.Record, include_metadata=False): content_id: str content: str app = faust.App( "faust-poc", broker="aiokafka://kafka:9092", store="memory://",...

vmaurin

Still fetching changelog topics for recovery

4

## Steps to reproduce We have a test platform that works fine. We have some topics (all have 3 partitions) linked to some records and some RocksDB tables storing some...

pythoniste

The app initialization gets stuck after upgrading to version 0.10.1

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

xcarlosamm

Why doesn't Event.forward default to the timestamp of the event?

1

So in Event.forward: https://github.com/faust-streaming/faust/blob/master/faust/events.py#L167 which is used by the Stream.group_by: https://github.com/faust-streaming/faust/blob/master/faust/streams.py#L890 When using `group_by`, the original timestamp of the event is lost. In the case of the windowing I'm experimenting...

cowboygneox

https://github.com/faust-streaming/faust/blob/master/faust/tables/base.py#L564 It looks like when using the `.delta(timedelta)`, the delta does not respect if the table was configured to use a different relative relationship, whether it be `relative_to_now` or `relative_to_field`....

cowboygneox

Errors with python3.11 with concurrency and high event rates

6

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

krzysieksulejczak

Building on the concepts of faust-streaming, we built out a micro-service orchestration/workflow engine - [Dagger](https://github.com/wayfair-incubator/dagger). Dagger operates at Faust scale to handle millions of long running tasks. It works similar...

patkivikram