I like this async kafka package.

I guess I think something wrong at manager.py line 96. I changed it to schema["name"] = f'{schema["name"]}{self._suffix}'

I am a new developer, where can I create a ticket and corresponding branch if I want to help?

Hi!

I just stumbled over this schema-registry/serializer project b.c. I was about to implement one myself =)

Where I work we have a working serializer/deserializer talking to the confluent schema registry, but it's a bit of a hack.
The schema fetching is done separately in a startup script before starting the consumer/producer, and the schemas are put into the aiohttp app container, so we have to lug that around everywhere.

So I was wondering if this library is ready for use yet? I noticed it's very new (january of this year).

Hi! Thanks again for a really useful library.

I'm working on moving centrally managed schemas into the application that actually owns them, and I've stumbled on an issue with the register_schema method.

We're using avro encoding for the keys as well as the values in the kafka messages, and in this instance the key schema is just a simple string schema. All schemas owned by the application share the same key schema.

I noticed that when testing schema creation from the application using kafkit, only the key schema for the first subject is actually created in the schema registry, the others get short circuited in the register_schema method here:

This becomes a problem when other clients rely on the key schema_id being registered under the other subject as well in the schema registry, and they now crash when they can't find a key-schema for their subjects.

Update: A quick workaround for this problem is to wipe the schema cache in the registry manually when I loop through the schemas I need to make sure exist in the confluent schema registry, like so:

registry._schema_cache = SchemaCache()

I'm happy to provide a PR with a solution when I know a bit more about the rationale and use case for short circuiting the schema registering.

This is a very promising and appealing library which I'd love to make use of in my projects at work, however I notice maintainership has dropped off in the last year or so. Is this library currently maintained? Are their plans to continue maintainership?

I'm happy to help move issues along and publish updates.

I have a schema registry url and I want to build kafka consumers, Currently I don't have access to the schema files.
What should I do to fetch all relevant schemas for the topics I want to listen to?
I can only spot a register method to register schemas to the registry and serialize method to serialize messages.
What should I do so that I can deserialize messages?

I am using kafkit version 0.2.1