New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Custom SchemaReader/SchemaWriter are not working for Avro schemas #8430
Comments
@congbobo184 Could you please take a look at this issue? |
@geomagilles #8464 this PR add the support of avro schema user define reader and writer and add a interface to handle the multi version schema. you can define the reader and writer by yourself. |
@congbobo184 Thx! I'm not able to run the PR myself as I do not manage yet to run Pulsar from sources - but it seems good to me. Note: I'm not sure what is the purpose of the getSchemaReaderBySchemaInfo interface - can you clarify that for me, please? |
@geomagilles hello, if use AvroSchema will have multi version schema, so we should generate different version reader to decode the data. this PR will change, add the MultiVersionReader to solve the question. |
@congbobo184 thx - do you think it could be included in the next release? |
@geomagilles 2.6.2 have been voted, so it will move to 2.7.0, 2.7.0 will release immediately after 2.6.2 finish. |
ok, thx |
Describe the bug
When using
Schema.AVRO(mySchemaDefinition)
custom SchemaWriter/SchemaReader provided inmySchemaDefinition
are not used even if present inmySchemaDefinition
.The use case is to be able to serialize/deserialize Kotlin data classes using avro4k package by providing custom Avro reader/writer.
Expected behavior
This could work
Additional context
Apparently a similar issue was solved for Json Schema (#6528 (comment))
The text was updated successfully, but these errors were encountered: