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..72f26a106 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)