You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I'm running a supported version of the application which is listed here and the feature is not present there
Is your proposal related to a problem?
I have a producer on Kafka. I have no control about the producer and the producer does not set the magic byte and schema id in avro that would tell a consumer what schema to use. However I want to inspect the messages in Kafka UI.
Describe the feature you're interested in
I want to be able to set the correct schema.
When Serializing messages the code in SchemaRegistrySerde has a look into the registry using the topic name.
Suggestion:
When Deserializing:
Have a look at magic byte and schema ID
If no schema ID set have a look in the registry using the topic name and try this schema
Fail otherwise
-> Suggestion add step 2
Describe alternatives you've considered
Setting the magic bytes and schema ids in messages. However in a lot of cases the read does not control the producer.
Setting the correct schema via UI.
Thank you and congratulations 🎉 for opening your very first issue in this project! 💖
In case you want to claim this issue, please comment down below! We will try to get back to you as soon as we can. 👀
1-alex98
changed the title
Avro deserialization without magic byte
SchemaRegistrySerde Avro deserialization without magic byte using lookup by topic name as fallback like in serialization
Mar 4, 2025
1-alex98
changed the title
SchemaRegistrySerde Avro deserialization without magic byte using lookup by topic name as fallback like in serialization
SchemaRegistrySerde: Avro deserialization without magic byte using lookup by topic name as fallback like in serialization
Mar 4, 2025
1-alex98
added a commit
to 1-alex98/kafka-ui
that referenced
this issue
Mar 4, 2025
Issue submitter TODO list
Is your proposal related to a problem?
I have a producer on Kafka. I have no control about the producer and the producer does not set the magic byte and schema id in avro that would tell a consumer what schema to use. However I want to inspect the messages in Kafka UI.
Describe the feature you're interested in
I want to be able to set the correct schema.
When Serializing messages the code in SchemaRegistrySerde has a look into the registry using the topic name.
Suggestion:
When Deserializing:
-> Suggestion add step 2
Describe alternatives you've considered
Setting the magic bytes and schema ids in messages. However in a lot of cases the read does not control the producer.
Setting the correct schema via UI.
Version you're running
Applies to all versions
Additional context
kafka-ui/kafka-ui-api/src/main/java/com/provectus/kafka/ui/serdes/builtin/sr/SchemaRegistrySerde.java
Line 303 in 83b5a60
Currently only reads the schema from the message it-self
The text was updated successfully, but these errors were encountered: