diff --git a/src/kafkit/registry/manager.py b/src/kafkit/registry/manager.py index ad555dd..83fc086 100644 --- a/src/kafkit/registry/manager.py +++ b/src/kafkit/registry/manager.py @@ -93,7 +93,7 @@ def _load_schemas(self) -> None: schema = json.loads(schema_path.read_text()) if self._suffix: - schema["name"] = f'schema["name"]{self._suffix}' + schema["name"] = f'{schema["name"]}{self._suffix}' fqn = self._get_fqn(schema) self.schemas[fqn] = schema