From 2f188db36fc60a76896194c67e3d2ab13f1e845d Mon Sep 17 00:00:00 2001 From: Julin <142230457+c-julin@users.noreply.github.com> Date: Tue, 20 Jan 2026 13:57:00 +0000 Subject: [PATCH 1/6] feat(schema-registry): improve schema metadata UI - Add Properties subheading under Metadata section - Display metadata properties in a table format - Load existing metadata when adding new schema version - Fix version selection to show latest after creating new version - Invalidate React Query cache after schema creation --- .../pages/schemas/schema-create.tsx | 99 +++++++++++++++++-- .../pages/schemas/schema-details.tsx | 50 ++++++++++ 2 files changed, 143 insertions(+), 6 deletions(-) diff --git a/frontend/src/components/pages/schemas/schema-create.tsx b/frontend/src/components/pages/schemas/schema-create.tsx index 2ace35f652..d9a0423504 100644 --- a/frontend/src/components/pages/schemas/schema-create.tsx +++ b/frontend/src/components/pages/schemas/schema-create.tsx @@ -23,8 +23,10 @@ import { IconButton, Input, RadioGroup, + Text, useToast, } from '@redpanda-data/ui'; +import { useQueryClient } from '@tanstack/react-query'; import { TrashIcon } from 'components/icons'; import { InfoIcon } from 'lucide-react'; import { observable } from 'mobx'; @@ -150,6 +152,16 @@ export class SchemaAddVersionPage extends PageComponent<{ subjectName: string }> this.editorState.references = schema.references; this.editorState.strategy = 'CUSTOM'; this.editorState.userInput = subject.name; + + // Load existing metadata properties for editing + if (schema.metadata?.properties) { + this.editorState.metadataProperties = Object.entries(schema.metadata.properties).map(([key, value]) => ({ + key, + value, + })); + // Add an empty row for adding new properties + this.editorState.metadataProperties.push({ key: '', value: '' }); + } } return ( @@ -176,6 +188,7 @@ const SchemaPageButtons = observer( editorState: SchemaEditorStateHelper; }) => { const toast = useToast(); + const queryClient = useQueryClient(); const [isValidating, setValidating] = useState(false); const [isCreating, setCreating] = useState(false); const [persistentValidationError, setPersistentValidationError] = useState<{ @@ -248,6 +261,7 @@ const SchemaPageButtons = observer( schemaType: editorState.format as SchemaTypeType, schema: editorState.schemaText, references: editorState.references.filter((x) => x.name && x.subject), + metadata: editorState.computedMetadata, params: { normalize: editorState.normalize, }, @@ -256,15 +270,17 @@ const SchemaPageButtons = observer( await api.refreshSchemaDetails(subjectName, true); - // success: navigate to details - const latestVersion = api.schemaDetails.get(subjectName)?.latestActiveVersion; + // Invalidate React Query cache so details page shows latest data + await queryClient.invalidateQueries({ + queryKey: ['schemaRegistry', 'subjects', subjectName, 'details'], + }); + + // success: navigate to details with "latest" so it picks up the new version // biome-ignore lint/suspicious/noConsole: intentional console usage console.log('schema created', { response: r }); // biome-ignore lint/suspicious/noConsole: intentional console usage - console.log('navigating to details', { subjectName, latestVersion }); - appGlobal.historyReplace( - `/schema-registry/subjects/${encodeURIComponent(subjectName)}?version=${latestVersion}` - ); + console.log('navigating to details', { subjectName }); + appGlobal.historyReplace(`/schema-registry/subjects/${encodeURIComponent(subjectName)}?version=latest`); } catch (err) { // error: open modal // biome-ignore lint/suspicious/noConsole: intentional console usage @@ -547,6 +563,13 @@ const SchemaEditor = observer((p: { state: SchemaEditorStateHelper; mode: 'CREAT {/* This is an example help text about the references list, to be updated later */} + + + Schema metadata + + Optional key-value properties to associate with this schema. + + ); @@ -636,6 +659,59 @@ const ReferencesEditor = observer((p: { state: SchemaEditorStateHelper }) => { ); }); +const MetadataPropertiesEditor = observer((p: { state: SchemaEditorStateHelper }) => { + const { state } = p; + const props = state.metadataProperties; + + const renderRow = (prop: { key: string; value: string }, index: number) => ( + + + { + prop.key = e.target.value; + }} + placeholder="e.g. owner" + value={prop.key} + /> + + + { + prop.value = e.target.value; + }} + placeholder="e.g. team-platform" + value={prop.value} + /> + + } + onClick={() => props.remove(prop)} + variant="ghost" + /> + + ); + + return ( + + {props.map((x, index) => renderRow(x, index))} + + + + ); +}); + function createSchemaState() { return observable({ strategy: 'TOPIC' as @@ -654,6 +730,17 @@ function createSchemaState() { version: number; }[], normalize: false, + metadataProperties: [{ key: '', value: '' }] as { key: string; value: string }[], + + get computedMetadata(): { properties: Record } | undefined { + const properties: Record = {}; + for (const prop of this.metadataProperties) { + if (prop.key && prop.value) { + properties[prop.key] = prop.value; + } + } + return Object.keys(properties).length > 0 ? { properties } : undefined; + }, get isInvalidKeyOrValue() { return this.strategy === 'TOPIC' && this.userInput.length > 0 && !this.keyOrValue; diff --git a/frontend/src/components/pages/schemas/schema-details.tsx b/frontend/src/components/pages/schemas/schema-details.tsx index 1dc06a306b..b6892a8a5d 100644 --- a/frontend/src/components/pages/schemas/schema-details.tsx +++ b/frontend/src/components/pages/schemas/schema-details.tsx @@ -29,6 +29,7 @@ import { } from '@redpanda-data/ui'; import { useQueryClient } from '@tanstack/react-query'; import { getRouteApi, Link, useNavigate } from '@tanstack/react-router'; +import { Table, TableBody, TableCell, TableHead, TableHeader, TableRow } from 'components/redpanda-ui/components/table'; const routeApi = getRouteApi('/schema-registry/subjects/$subjectName/'); @@ -307,6 +308,13 @@ const SubjectDefinition = (p: { subject: SchemaRegistrySubjectDetails }) => { } }, [versionNumber, requestedVersionExists, fallbackVersion, toast, navigate]); + // When URL is "latest", sync selectedVersion with the actual latest version from data + useEffect(() => { + if (queryVersion === 'latest' && fallbackVersion && selectedVersion !== fallbackVersion) { + setSelectedVersion(fallbackVersion); + } + }, [queryVersion, fallbackVersion, selectedVersion]); + const schema = subjectData.schemas.first((x) => x.version === selectedVersion); useEffect(() => { @@ -645,6 +653,46 @@ const VersionDiff = (p: { subject: SchemaRegistrySubjectDetails }) => { ); }; +const SchemaMetadataSection = ({ schema }: { schema: SchemaRegistryVersionedSchema }) => { + const metadata = schema.metadata; + const properties = metadata?.properties; + const hasProperties = properties && Object.keys(properties).length > 0; + + return ( + <> + + Metadata + + Metadata associated with this schema version. + + + Properties + + + {hasProperties ? ( + + + + Key + Value + + + + {Object.entries(properties).map(([key, value]) => ( + + {key} + {value} + + ))} + +
+ ) : ( + No properties defined. + )} + + ); +}; + const SchemaReferences = (p: { subject: SchemaRegistrySubjectDetails; schema: SchemaRegistryVersionedSchema }) => { const { subject, schema } = p; const version = schema.version; @@ -654,6 +702,8 @@ const SchemaReferences = (p: { subject: SchemaRegistrySubjectDetails; schema: Sc return ( <> + + References From db750d2f4b3ceba94e76af54f935ec9c4ce1e24d Mon Sep 17 00:00:00 2001 From: Julin <142230457+c-julin@users.noreply.github.com> Date: Tue, 20 Jan 2026 13:57:12 +0000 Subject: [PATCH 2/6] feat(schema-registry): add metadata support to schema responses - Add SchemaMetadata struct with tags, properties, and sensitive fields - Map metadata from franz-go schema responses - Add integration tests for metadata handling --- ...handle_schema_registry_integration_test.go | 90 +++++++++++++++++++ backend/pkg/console/schema_registry.go | 31 +++++-- frontend/src/state/rest-interfaces.ts | 8 ++ 3 files changed, 123 insertions(+), 6 deletions(-) diff --git a/backend/pkg/api/handle_schema_registry_integration_test.go b/backend/pkg/api/handle_schema_registry_integration_test.go index 77f6348e23..c4e117dd24 100644 --- a/backend/pkg/api/handle_schema_registry_integration_test.go +++ b/backend/pkg/api/handle_schema_registry_integration_test.go @@ -337,3 +337,93 @@ enum MyEnumA { assert.Equal(thirdSchemaID, fourthSchemaID, "with normalize=true, schemas with different enum value order should produce the same schema ID") }) } + +func (s *APIIntegrationTestSuite) TestSchemaMetadata() { + t := s.T() + t.Skip() //todo remove skip once redpanda v26.1 is GA + require := require.New(t) + assert := assert.New(t) + + t.Run("create schema with metadata properties", func(t *testing.T) { + ctx, cancel := context.WithTimeout(t.Context(), 30*time.Second) + defer cancel() + + schemaStr := `{"type":"record","name":"User","fields":[{"name":"id","type":"string"}]}` + req := struct { + Schema string `json:"schema"` + Type string `json:"schemaType"` + Metadata struct { + Properties map[string]string `json:"properties"` + } `json:"metadata"` + }{ + Schema: schemaStr, + Type: sr.TypeAvro.String(), + } + req.Metadata.Properties = map[string]string{ + "owner": "team-platform", + "version": "1.0.0", + } + + res, body := s.apiRequest(ctx, http.MethodPost, "/api/schema-registry/subjects/test-metadata/versions", req) + require.Equal(200, res.StatusCode) + + createResponse := struct { + ID int `json:"id"` + }{} + err := json.Unmarshal(body, &createResponse) + require.NoError(err) + assert.Greater(createResponse.ID, 0, "schema ID should be returned") + }) + + t.Run("retrieve schema with metadata", func(t *testing.T) { + ctx, cancel := context.WithTimeout(t.Context(), 30*time.Second) + defer cancel() + + res, body := s.apiRequest(ctx, http.MethodGet, "/api/schema-registry/subjects/test-metadata/versions/latest", nil) + require.Equal(200, res.StatusCode) + + var details console.SchemaRegistrySubjectDetails + err := json.Unmarshal(body, &details) + require.NoError(err) + + // Verify metadata is present in response + require.Len(details.Schemas, 1, "should have one schema") + require.NotNil(details.Schemas[0].Metadata, "metadata should not be nil") + assert.Equal("team-platform", details.Schemas[0].Metadata.Properties["owner"], "owner property should match") + assert.Equal("1.0.0", details.Schemas[0].Metadata.Properties["version"], "version property should match") + }) + + t.Run("create schema without metadata (backward compatibility)", func(t *testing.T) { + ctx, cancel := context.WithTimeout(t.Context(), 30*time.Second) + defer cancel() + + schemaStr := `{"type":"record","name":"Event","fields":[{"name":"id","type":"string"}]}` + req := struct { + Schema string `json:"schema"` + Type string `json:"schemaType"` + }{ + Schema: schemaStr, + Type: sr.TypeAvro.String(), + } + + res, body := s.apiRequest(ctx, http.MethodPost, "/api/schema-registry/subjects/test-no-metadata/versions", req) + require.Equal(200, res.StatusCode) + + createResponse := struct { + ID int `json:"id"` + }{} + err := json.Unmarshal(body, &createResponse) + require.NoError(err) + assert.Greater(createResponse.ID, 0, "schema ID should be returned") + + // Verify schema without metadata retrieves correctly + res, body = s.apiRequest(ctx, http.MethodGet, "/api/schema-registry/subjects/test-no-metadata/versions/latest", nil) + require.Equal(200, res.StatusCode) + + var details console.SchemaRegistrySubjectDetails + err = json.Unmarshal(body, &details) + require.NoError(err) + require.Len(details.Schemas, 1, "should have one schema") + assert.Nil(details.Schemas[0].Metadata, "metadata should be nil for schema without metadata") + }) +} diff --git a/backend/pkg/console/schema_registry.go b/backend/pkg/console/schema_registry.go index ce2689aa94..6ec0f54a67 100644 --- a/backend/pkg/console/schema_registry.go +++ b/backend/pkg/console/schema_registry.go @@ -186,6 +186,16 @@ func mapSubjectSchema(in sr.SubjectSchema, isSoftDeleted bool) SchemaRegistryVer Version: ref.Version, } } + + var metadata *SchemaMetadata + if in.Schema.SchemaMetadata != nil { + metadata = &SchemaMetadata{ + Tags: in.Schema.SchemaMetadata.Tags, + Properties: in.Schema.SchemaMetadata.Properties, + Sensitive: in.Schema.SchemaMetadata.Sensitive, + } + } + return SchemaRegistryVersionedSchema{ ID: in.ID, Version: in.Version, @@ -193,6 +203,7 @@ func mapSubjectSchema(in sr.SubjectSchema, isSoftDeleted bool) SchemaRegistryVer Type: in.Type, Schema: in.Schema.Schema, References: references, + Metadata: metadata, } } @@ -395,12 +406,13 @@ func (s *Service) getSubjectCompatibilityLevel(ctx context.Context, srClient *rp // SchemaRegistryVersionedSchema describes a retrieved schema. type SchemaRegistryVersionedSchema struct { - ID int `json:"id"` - Version int `json:"version"` - IsSoftDeleted bool `json:"isSoftDeleted"` - Type sr.SchemaType `json:"type"` - Schema string `json:"schema"` - References []Reference `json:"references"` + ID int `json:"id"` + Version int `json:"version"` + IsSoftDeleted bool `json:"isSoftDeleted"` + Type sr.SchemaType `json:"type"` + Schema string `json:"schema"` + References []Reference `json:"references"` + Metadata *SchemaMetadata `json:"metadata,omitempty"` } // Reference describes a reference to a different schema stored in the schema registry. @@ -410,6 +422,13 @@ type Reference struct { Version int `json:"version"` } +// SchemaMetadata contains metadata associated with a schema version. +type SchemaMetadata struct { + Tags map[string][]string `json:"tags,omitempty"` + Properties map[string]string `json:"properties,omitempty"` + Sensitive []string `json:"sensitive,omitempty"` +} + // GetSchemaRegistrySchema retrieves a schema for a given subject, version tuple from the // schema registry. You can use -1 as the version to return the latest schema, func (s *Service) GetSchemaRegistrySchema(ctx context.Context, subjectName string, version int, showSoftDeleted bool) (*SchemaRegistryVersionedSchema, error) { diff --git a/frontend/src/state/rest-interfaces.ts b/frontend/src/state/rest-interfaces.ts index 43f199eeef..a4fbed25fc 100644 --- a/frontend/src/state/rest-interfaces.ts +++ b/frontend/src/state/rest-interfaces.ts @@ -1518,6 +1518,7 @@ export type SchemaRegistryVersionedSchema = { type: SchemaTypeType; schema: string; references: SchemaReference[]; + metadata?: SchemaMetadata; }; export type SchemaReference = { @@ -1526,6 +1527,12 @@ export type SchemaReference = { version: number; }; +export type SchemaMetadata = { + tags?: Record; + properties?: Record; + sensitive?: string[]; +}; + // DELETE /schema-registry/subjects/{subject}/versions/{version} export type SchemaRegistryDeleteSubjectVersionResponse = { deletedVersion: number; @@ -1541,6 +1548,7 @@ export type SchemaRegistryCreateSchema = { schema: string; schemaType: SchemaTypeType; references: SchemaReference[]; + metadata?: SchemaMetadata; params?: { normalize?: boolean; }; From c1f0706b0b76a7c3fb1cf421c6c003a63b451b43 Mon Sep 17 00:00:00 2001 From: Julin <142230457+c-julin@users.noreply.github.com> Date: Wed, 21 Jan 2026 12:19:04 +0000 Subject: [PATCH 3/6] fix: resolve golangci-lint errors for schema registry - Fix gci import ordering by grouping redpanda-data imports separately - Remove redundant embedded field .Schema from selectors (staticcheck QF1008) - Fix comment formatting for gofumpt compliance --- ...handle_schema_registry_integration_test.go | 2 +- backend/pkg/console/schema_registry.go | 22 +++++++++---------- 2 files changed, 12 insertions(+), 12 deletions(-) diff --git a/backend/pkg/api/handle_schema_registry_integration_test.go b/backend/pkg/api/handle_schema_registry_integration_test.go index c4e117dd24..21fb35349c 100644 --- a/backend/pkg/api/handle_schema_registry_integration_test.go +++ b/backend/pkg/api/handle_schema_registry_integration_test.go @@ -340,7 +340,7 @@ enum MyEnumA { func (s *APIIntegrationTestSuite) TestSchemaMetadata() { t := s.T() - t.Skip() //todo remove skip once redpanda v26.1 is GA + t.Skip() // todo remove skip once redpanda v26.1 is GA require := require.New(t) assert := assert.New(t) diff --git a/backend/pkg/console/schema_registry.go b/backend/pkg/console/schema_registry.go index 6ec0f54a67..2dd893ebe8 100644 --- a/backend/pkg/console/schema_registry.go +++ b/backend/pkg/console/schema_registry.go @@ -188,11 +188,11 @@ func mapSubjectSchema(in sr.SubjectSchema, isSoftDeleted bool) SchemaRegistryVer } var metadata *SchemaMetadata - if in.Schema.SchemaMetadata != nil { + if in.SchemaMetadata != nil { metadata = &SchemaMetadata{ - Tags: in.Schema.SchemaMetadata.Tags, - Properties: in.Schema.SchemaMetadata.Properties, - Sensitive: in.Schema.SchemaMetadata.Sensitive, + Tags: in.SchemaMetadata.Tags, + Properties: in.SchemaMetadata.Properties, + Sensitive: in.SchemaMetadata.Sensitive, } } @@ -406,13 +406,13 @@ func (s *Service) getSubjectCompatibilityLevel(ctx context.Context, srClient *rp // SchemaRegistryVersionedSchema describes a retrieved schema. type SchemaRegistryVersionedSchema struct { - ID int `json:"id"` - Version int `json:"version"` - IsSoftDeleted bool `json:"isSoftDeleted"` - Type sr.SchemaType `json:"type"` - Schema string `json:"schema"` - References []Reference `json:"references"` - Metadata *SchemaMetadata `json:"metadata,omitempty"` + ID int `json:"id"` + Version int `json:"version"` + IsSoftDeleted bool `json:"isSoftDeleted"` + Type sr.SchemaType `json:"type"` + Schema string `json:"schema"` + References []Reference `json:"references"` + Metadata *SchemaMetadata `json:"metadata,omitempty"` } // Reference describes a reference to a different schema stored in the schema registry. From 3e307d18e6114b0df7d616b84ab46ba751fe4352 Mon Sep 17 00:00:00 2001 From: Julin <142230457+c-julin@users.noreply.github.com> Date: Thu, 22 Jan 2026 13:19:19 +0000 Subject: [PATCH 4/6] chore: remove console.log statements from schema-create Remove debug console.log calls per code standards which only allow console.error and console.warn for actionable errors. --- frontend/src/components/pages/schemas/schema-create.tsx | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) diff --git a/frontend/src/components/pages/schemas/schema-create.tsx b/frontend/src/components/pages/schemas/schema-create.tsx index d9a0423504..4d8d7bc409 100644 --- a/frontend/src/components/pages/schemas/schema-create.tsx +++ b/frontend/src/components/pages/schemas/schema-create.tsx @@ -256,7 +256,7 @@ const SchemaPageButtons = observer( setCreating(true); try { const subjectName = editorState.computedSubjectName; - const r = await api + await api .createSchema(editorState.computedSubjectName, { schemaType: editorState.format as SchemaTypeType, schema: editorState.schemaText, @@ -276,15 +276,8 @@ const SchemaPageButtons = observer( }); // success: navigate to details with "latest" so it picks up the new version - // biome-ignore lint/suspicious/noConsole: intentional console usage - console.log('schema created', { response: r }); - // biome-ignore lint/suspicious/noConsole: intentional console usage - console.log('navigating to details', { subjectName }); appGlobal.historyReplace(`/schema-registry/subjects/${encodeURIComponent(subjectName)}?version=latest`); } catch (err) { - // error: open modal - // biome-ignore lint/suspicious/noConsole: intentional console usage - console.log('failed to create schema', { err }); toast({ status: 'error', duration: undefined, From 551579a4f8e566784e07781540f5cb819095bec1 Mon Sep 17 00:00:00 2001 From: Julin <142230457+c-julin@users.noreply.github.com> Date: Thu, 22 Jan 2026 14:08:38 +0000 Subject: [PATCH 5/6] fix: graceful handling of parsing error if schema metadata is used against old version of redpanda that does not support metadata. --- backend/pkg/console/schema_registry.go | 12 ++++++++++++ .../src/components/pages/schemas/schema-create.tsx | 4 +++- .../src/components/pages/schemas/schema-details.tsx | 8 +++++++- 3 files changed, 22 insertions(+), 2 deletions(-) diff --git a/backend/pkg/console/schema_registry.go b/backend/pkg/console/schema_registry.go index 2dd893ebe8..54d3701d04 100644 --- a/backend/pkg/console/schema_registry.go +++ b/backend/pkg/console/schema_registry.go @@ -604,6 +604,18 @@ func (s *Service) CreateSchemaRegistrySchema(ctx context.Context, subjectName st subjectSchema, err := srClient.CreateSchema(ctx, subjectName, schema) if err != nil { + // If metadata was included and we got a parse error, retry without metadata. + // Older Redpanda versions don't support the metadata field. + if schema.SchemaMetadata != nil { + s.logger.Warn("retrying schema creation without metadata (unsupported by this Redpanda version)", + slog.String("subject", subjectName)) + schema.SchemaMetadata = nil + subjectSchema, err = srClient.CreateSchema(ctx, subjectName, schema) + if err != nil { + return nil, err + } + return &CreateSchemaResponse{ID: subjectSchema.ID}, nil + } return nil, err } diff --git a/frontend/src/components/pages/schemas/schema-create.tsx b/frontend/src/components/pages/schemas/schema-create.tsx index 4d8d7bc409..2b6195b6fe 100644 --- a/frontend/src/components/pages/schemas/schema-create.tsx +++ b/frontend/src/components/pages/schemas/schema-create.tsx @@ -560,7 +560,9 @@ const SchemaEditor = observer((p: { state: SchemaEditorStateHelper; mode: 'CREAT Schema metadata - Optional key-value properties to associate with this schema. + + Optional key-value properties to associate with this schema. Metadata will be ignored if not supported by schema registry. + diff --git a/frontend/src/components/pages/schemas/schema-details.tsx b/frontend/src/components/pages/schemas/schema-details.tsx index b6892a8a5d..1c5ce2e8cb 100644 --- a/frontend/src/components/pages/schemas/schema-details.tsx +++ b/frontend/src/components/pages/schemas/schema-details.tsx @@ -29,6 +29,7 @@ import { } from '@redpanda-data/ui'; import { useQueryClient } from '@tanstack/react-query'; import { getRouteApi, Link, useNavigate } from '@tanstack/react-router'; +import { Empty, EmptyDescription, EmptyHeader, EmptyTitle } from 'components/redpanda-ui/components/empty'; import { Table, TableBody, TableCell, TableHead, TableHeader, TableRow } from 'components/redpanda-ui/components/table'; const routeApi = getRouteApi('/schema-registry/subjects/$subjectName/'); @@ -687,7 +688,12 @@ const SchemaMetadataSection = ({ schema }: { schema: SchemaRegistryVersionedSche ) : ( - No properties defined. + + + No properties + No properties defined for this schema version. + + )} ); From 12d8d053b8abbf3dd56ab0533e68902b824ab187 Mon Sep 17 00:00:00 2001 From: Julin <142230457+c-julin@users.noreply.github.com> Date: Thu, 22 Jan 2026 14:20:52 +0000 Subject: [PATCH 6/6] fix: graceful handling of parsing error if schema metadata is used against old version of redpanda that does not support metadata. --- backend/pkg/console/schema_registry.go | 2 +- frontend/src/components/pages/schemas/schema-create.tsx | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/backend/pkg/console/schema_registry.go b/backend/pkg/console/schema_registry.go index 54d3701d04..b4e100486b 100644 --- a/backend/pkg/console/schema_registry.go +++ b/backend/pkg/console/schema_registry.go @@ -607,7 +607,7 @@ func (s *Service) CreateSchemaRegistrySchema(ctx context.Context, subjectName st // If metadata was included and we got a parse error, retry without metadata. // Older Redpanda versions don't support the metadata field. if schema.SchemaMetadata != nil { - s.logger.Warn("retrying schema creation without metadata (unsupported by this Redpanda version)", + s.logger.WarnContext(ctx, "retrying schema creation without metadata (unsupported by this Redpanda version)", slog.String("subject", subjectName)) schema.SchemaMetadata = nil subjectSchema, err = srClient.CreateSchema(ctx, subjectName, schema) diff --git a/frontend/src/components/pages/schemas/schema-create.tsx b/frontend/src/components/pages/schemas/schema-create.tsx index 2b6195b6fe..7940238cd5 100644 --- a/frontend/src/components/pages/schemas/schema-create.tsx +++ b/frontend/src/components/pages/schemas/schema-create.tsx @@ -561,7 +561,8 @@ const SchemaEditor = observer((p: { state: SchemaEditorStateHelper; mode: 'CREAT Schema metadata - Optional key-value properties to associate with this schema. Metadata will be ignored if not supported by schema registry. + Optional key-value properties to associate with this schema. Metadata will be ignored if not supported by + schema registry.