GlobalTable doesnt respect schema - Githubissues

faust-streaming / faust

Python Stream Processing. A Faust fork

https://faust-streaming.github.io/faust/

Other

1.66k stars 183 forks source link

GlobalTable doesnt respect schema #632

Open kokorins opened 4 months ago

kokorins commented 4 months ago

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 reproduce

Tell us what you did to cause something to happen.

table = app.GlobalTable(
      "name"
        schema=faust.Schema(
            value_serializer=PydanticJsonSerializer(PydanticModelDerivative),
        ),
)

## Expected behavior

I've set up a custom codec for value_serializer on schema of a GlobalTable. This works well if GlobalTable is replaced with just Table.

## Actual behavior

Default codec is in use.

<Schema: KT=default (json) VT=default (json)>



# Versions

* Python version: 3.11
* Faust version: 0.11.0
* Operating system: ubuntu 22.04
* Kafka version: -
* RocksDB version (if applicable): -