faust icon indicating copy to clipboard operation
faust copied to clipboard

GlobalTable doesnt respect schema

Open kokorins opened this issue 7 months ago • 0 comments

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): -

kokorins avatar Jul 12 '24 11:07 kokorins