IS bytewax able to work with avro messages yet

[Isuc0100]

Just wondering as I am trying to implement something involving avro messages but encountering some issues

[whoahbot]

Hi @Isuc0100. What kinds of issues are you encountering with Avro messages?

[Isuc0100]

When trying to deserialize i keep encountering an error when it reaches the flow.map(deserialize) stating a type error for the map mapper which says its caused by parameter 'ctx' is unfilled

[whoahbot]

Hm, that error doesn't sound familiar. Do you have a small code sample we can look at to see if we can reproduce the problem here?

[gyunt]

I had the same experience when using dataclasses-avroschema, but the reason for the errors is that deserialization is not thread-safe.

[awmatheson]

If you are using Confluent or Redpanda Schema Registry, you can take advantage of avro deserialization.

confluent example - https://github.com/bytewax/bytewax/blob/a68de35a2df6099d2aa976e0e77df3e9de68c077/examples/schema_registry_confluent.py
redpanda example - https://github.com/bytewax/bytewax/blob/a68de35a2df6099d2aa976e0e77df3e9de68c077/examples/schema_registry_redpanda.py

You can also see how this is done internally here if you are interested in implementing your own.