From c6f0ef1f098570515cbe3aaa8199211cd2a9509c Mon Sep 17 00:00:00 2001 From: Naxin Date: Fri, 1 Aug 2025 13:48:04 -0400 Subject: [PATCH 1/2] fix --- .../schema_registry/_async/schema_registry_client.py | 10 +++++----- .../schema_registry/_sync/schema_registry_client.py | 10 +++++----- 2 files changed, 10 insertions(+), 10 deletions(-) diff --git a/src/confluent_kafka/schema_registry/_async/schema_registry_client.py b/src/confluent_kafka/schema_registry/_async/schema_registry_client.py index f4ca12c32..93ec40eb8 100644 --- a/src/confluent_kafka/schema_registry/_async/schema_registry_client.py +++ b/src/confluent_kafka/schema_registry/_async/schema_registry_client.py @@ -753,7 +753,7 @@ async def lookup_schema( SchemaRegistryError: If schema or subject can't be found See Also: - `POST Subject API Reference `_ + `POST Subject API Reference `_ """ # noqa: E501 registered_schema = self._cache.get_registered_by_subject_schema(subject_name, schema) @@ -785,7 +785,7 @@ async def lookup_schema( async def get_subjects(self) -> List[str]: """ - List all subjects registered with the Schema Registry + Lists all subjects registered with the Schema Registry Returns: list(str): Registered subject names @@ -794,7 +794,7 @@ async def get_subjects(self) -> List[str]: SchemaRegistryError: if subjects can't be found See Also: - `GET subjects API Reference `_ + `GET subjects API Reference `_ """ # noqa: E501 return await self._rest_client.get('subjects') @@ -908,7 +908,7 @@ async def get_latest_with_metadata( return registered_schema async def get_version( - self, subject_name: str, version: int, + self, subject_name: str, version: Union[int, str] = "latest",, deleted: bool = False, fmt: Optional[str] = None ) -> 'RegisteredSchema': """ @@ -927,7 +927,7 @@ async def get_version( SchemaRegistryError: if the version can't be found or is invalid. See Also: - `GET Subject Version API Reference `_ + `GET Subject Versions API Reference `_ """ # noqa: E501 registered_schema = self._cache.get_registered_by_subject_version(subject_name, version) diff --git a/src/confluent_kafka/schema_registry/_sync/schema_registry_client.py b/src/confluent_kafka/schema_registry/_sync/schema_registry_client.py index 2394172c4..3be266538 100644 --- a/src/confluent_kafka/schema_registry/_sync/schema_registry_client.py +++ b/src/confluent_kafka/schema_registry/_sync/schema_registry_client.py @@ -753,7 +753,7 @@ def lookup_schema( SchemaRegistryError: If schema or subject can't be found See Also: - `POST Subject API Reference `_ + `POST Subject API Reference `_ """ # noqa: E501 registered_schema = self._cache.get_registered_by_subject_schema(subject_name, schema) @@ -785,7 +785,7 @@ def lookup_schema( def get_subjects(self) -> List[str]: """ - List all subjects registered with the Schema Registry + Lists all subjects registered with the Schema Registry Returns: list(str): Registered subject names @@ -794,7 +794,7 @@ def get_subjects(self) -> List[str]: SchemaRegistryError: if subjects can't be found See Also: - `GET subjects API Reference `_ + `GET subjects API Reference `_ """ # noqa: E501 return self._rest_client.get('subjects') @@ -908,7 +908,7 @@ def get_latest_with_metadata( return registered_schema def get_version( - self, subject_name: str, version: int, + self, subject_name: str, version: Union[int, str] = "latest", deleted: bool = False, fmt: Optional[str] = None ) -> 'RegisteredSchema': """ @@ -927,7 +927,7 @@ def get_version( SchemaRegistryError: if the version can't be found or is invalid. See Also: - `GET Subject Version API Reference `_ + `GET Subject Versions API Reference `_ """ # noqa: E501 registered_schema = self._cache.get_registered_by_subject_version(subject_name, version) From f73ab1f3674074f64c14fa903aba7f3e03c679ef Mon Sep 17 00:00:00 2001 From: Naxin Date: Fri, 1 Aug 2025 13:52:12 -0400 Subject: [PATCH 2/2] typo --- .../schema_registry/_async/schema_registry_client.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/confluent_kafka/schema_registry/_async/schema_registry_client.py b/src/confluent_kafka/schema_registry/_async/schema_registry_client.py index 93ec40eb8..72f26a106 100644 --- a/src/confluent_kafka/schema_registry/_async/schema_registry_client.py +++ b/src/confluent_kafka/schema_registry/_async/schema_registry_client.py @@ -908,7 +908,7 @@ async def get_latest_with_metadata( return registered_schema async def get_version( - self, subject_name: str, version: Union[int, str] = "latest",, + self, subject_name: str, version: Union[int, str] = "latest", deleted: bool = False, fmt: Optional[str] = None ) -> 'RegisteredSchema': """