You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2022/07/30 08:14:44 UTC
[rocketmq-schema-registry] 26/27: fix client
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 <yi...@163.com>
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);
-
}