faust
faust copied to clipboard
GlobalTable doesnt respect schema
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): -