aiokafka icon indicating copy to clipboard operation
aiokafka copied to clipboard

[QUESTION] add schema registry url

Open hamroune opened this issue 5 years ago • 2 comments

Hi everyone, I can't find option to set schema registry url, can some one help me to point the right way to add Avro Schema based on Schema Registry? thanks

hamroune avatar May 16 '20 07:05 hamroune

I don't believe that any of the 2 clients (sync and async) support schema registry integration at the moment. That being said , you can peek at my failed attempt to create a schema registry serializer here https://github.com/aiven/karapace/blob/performance-improvements/karapace/serialization.py .

It's failed because we ended up needing a different interface that the one currently provided by the python client. And the http calls made to the registry were async, so the serialize/deserialize methods ended up being async as well.

That being said, the serializer can easily be adapted to fit said interface, provided one uses only a subject name strategy. Hope this clears things up somewhat

gabriel-tincu avatar May 20 '20 07:05 gabriel-tincu

kafkit is one option for a schema registry interface

r-owen avatar May 16 '22 19:05 r-owen