faust

faust copied to clipboard

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

dolshevsk

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

Xastur

Is there a way to assign the number of partitions on table dynamically relying on topic's number of partitions

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

dolshevsk

Faust agents die after some days

8

## Actual behavior After running the application for some days, agents die slowly and after a few days, no event consumes from topics. If I do not restart the docker...

alihoseiny

Readd Confluent Kafka drivers

3

Don't know why they were removed in https://github.com/faust-streaming/faust/commit/a0fb2242937770ea3bdce3a3d18cb789e337ad14, let's bring it back!

wbarnha

Raw integer as key cause Topic.publish_message crash

9

I suspect the `keysize` calculation is problematic for the raw integer key. https://github.com/faust-streaming/faust/blob/9a1cf927cb37441471794f2913be2351d52f2ece/faust/topics.py#L412 The key could be deserialized correctly with `Serdes.Integer()` in Java. I try to consume the message with...

iblislin

Model Validation is not working as expected

2

## Steps to reproduce ```python class Metadata(Record, validation=True, serializer='json'): desc:str=StringField(coerce=False) lolo:Optional[float] low:Optional[float] high:Optional[float] hihi:Optional[float] units:Optional[str] prec:Optional[int] ``` then try to initialise an instance with anything other than a string for...

fonty422

Consumer doesn't consume from some of its assigned partition

1

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

s34vv1nd

Support for pulsar streams in place of kafka. Other refs: https://github.com/robinhood/faust/issues/723

adyanth

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

joonjeong