This is an automated email from the ASF dual-hosted git repository. duhengforever pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-schema-registry.git
commit 682bf35e884f7f1825905eaff08c485ceb746541 Author: huitong <[email protected]> AuthorDate: Sat Jul 30 16:05:37 2022 +0800 fix client --- .../schema/registry/client/NormalSchemaRegistryClient.java | 13 ++----------- .../schema/registry/client/SchemaRegistryClient.java | 6 +----- 2 files changed, 3 insertions(+), 16 deletions(-) diff --git a/client/src/main/java/org/apache/rocketmq/schema/registry/client/NormalSchemaRegistryClient.java b/client/src/main/java/org/apache/rocketmq/schema/registry/client/NormalSchemaRegistryClient.java index 074dc76..263a55c 100644 --- a/client/src/main/java/org/apache/rocketmq/schema/registry/client/NormalSchemaRegistryClient.java +++ b/client/src/main/java/org/apache/rocketmq/schema/registry/client/NormalSchemaRegistryClient.java @@ -73,13 +73,14 @@ public class NormalSchemaRegistryClient implements SchemaRegistryClient { return restService.getSchemaBySubject(subject); } + @Override public SchemaRecordDto getSchemaBySubject(String cluster, String tenant, String subject) throws RestClientException, IOException { return restService.getSchemaBySubject(cluster, tenant, subject); } @Override - public SchemaRecordDto getSchemaBySubject(String cluster, String tenant, String subject, + public SchemaRecordDto getSchemaBySubjectAndVersion(String cluster, String tenant, String subject, long version) throws IOException, RestClientException { return restService.getSchemaBySubject(cluster, tenant, subject, version); } @@ -90,14 +91,4 @@ public class NormalSchemaRegistryClient implements SchemaRegistryClient { return restService.getSchemaListBySubject(cluster, tenant, subject); } - @Override - public SchemaRecordDto getSchemaById(long schemaId) { - throw new UnsupportedOperationException(); - } - - @Override - public SchemaRecordDto getSchemaBySubjectAndId(String subject, long schemaId) { - throw new UnsupportedOperationException(); - } - } diff --git a/client/src/main/java/org/apache/rocketmq/schema/registry/client/SchemaRegistryClient.java b/client/src/main/java/org/apache/rocketmq/schema/registry/client/SchemaRegistryClient.java index becd945..bf7c3d4 100644 --- a/client/src/main/java/org/apache/rocketmq/schema/registry/client/SchemaRegistryClient.java +++ b/client/src/main/java/org/apache/rocketmq/schema/registry/client/SchemaRegistryClient.java @@ -47,14 +47,10 @@ public interface SchemaRegistryClient { SchemaRecordDto getSchemaBySubject(String cluster, String tenant, String subject) throws IOException, RestClientException; - SchemaRecordDto getSchemaBySubject(String cluster, String tenant, String subject, + SchemaRecordDto getSchemaBySubjectAndVersion(String cluster, String tenant, String subject, long version) throws IOException, RestClientException; List<SchemaRecordDto> getSchemaListBySubject(String cluster, String tenant, String subject) throws RestClientException, IOException; - SchemaRecordDto getSchemaById(long schemaId); - - SchemaRecordDto getSchemaBySubjectAndId(String subject, long schemaId); - }
