faust

faust copied to clipboard

Question: Any idea on applying session window?

1

I have some tasks which is required to windowing stream into session just like in Kafka Stream. You can find example from the following link. Any idea to achieve this?...

praiwann

Default replication for replicas is 0 if replicas is None, is this a valid choice?

3

I am not very familiar with Kafka; however, when used with single instance Kafka and Redpanda on my development environment, RPC requests (agent.ask()) causes this error: ``` [^Worker]: Error: InvalidReplicationFactorError('Cannot...

mozcelebi

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

Faust channel and web are running a different loops

2

**Question:** Question previously asked here: https://github.com/robinhood/faust/issues/287 by somebody else. It seems that the web is running in a completely different loop from the rest of the app. At least sometimes....

popadi

Warning - producer buffer full

3

## Steps to reproduce We have several streaming agents, some update tables, some send to other topics. In a steady state this seems to work fine, however when ingesting peaking...

deadpassive

mypy fails to notice type mismatches in subclasses of faust.Record. However, the documentation explicitly mentions static typing and type checking and when going through the codebase, great care has been...

tarbaig

The persisted offset for changelog topic partition is higher than the last offset in that topic (highwater)

2

## Steps to reproduce I cannot reproduce it manually but it happens in the production environment sometimes. We have a single node environment that runs the solution via docker-compose. Kafka...

berimbolo13

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

ali-albuhussain

Difficulties serializing union types and enums to avro

2

## Checklist - [x] I have included information about relevant versions - `faust-streaming==0.6.9` and `faust-streaming==0.6.10`, haven't tried earlier. - [x] I have verified that the issue persists when using the...

BryceCicada

Faust *sometimes* crashes during rebalance when AeroSpike is used as storage engine

1

## Steps to reproduce There probably is a race condition during rebalancing when AeroSpike is used. If unlucky, a `TypeError` is encountered. ## Expected behavior No crashes on rebalance. ##...

xaralis