Skip to content

Adding support for optional and schemaless keys/values#724

Open
AnatolyPopov wants to merge 1 commit intomainfrom
anatolii/optional-key-value-schema
Open

Adding support for optional and schemaless keys/values#724
AnatolyPopov wants to merge 1 commit intomainfrom
anatolii/optional-key-value-schema

Conversation

@AnatolyPopov
Copy link
Copy Markdown
Contributor

Making key and value schemas optional

@AnatolyPopov AnatolyPopov requested a review from a team as a code owner August 25, 2025 06:40
Schema.createUnion(Schema.create(Schema.Type.NULL),
(Schema) valueDeserializer.getSchemaRegistryClient().getSchemaById(schemaId).rawSchema()),
schemaId);
} catch (final RestClientException e) {
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Don't generic network errors fall into this category?

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I believe yes but AFAIU it will be thrown only after exhausting all the allowed retry attempts. Or am I missing anything?

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I think if a network error happens, the plugin should fail as well. The result of this function cannot depend on network or schema registry availability.

@AnatolyPopov AnatolyPopov force-pushed the anatolii/optional-key-value-schema branch from 23fcc5b to 4ec4590 Compare August 25, 2025 15:44
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants