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

Author: c-julin

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")
+	})
+}

backend/pkg/console/schema_registry.go

@@ -186,13 +186,24 @@ 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,
 		IsSoftDeleted: isSoftDeleted,
 		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) {

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<string, string[]>;
+  properties?: Record<string, string>;
+  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;
   };