从合流架构注册表检索架构

Question

我正在尝试从模式注册表中检索给定kafka主题的模式主题版本。我可以使用client.register（schema-name,schema)成功发布新版本，但我不确定如何检索版本。我在下面尝试使用curl请求，但结果立即命中-1（空）。

CachedSchemaRegistryClient client = new CachedSchemaRegistryClient(schemaRegistryUrl, 20);

// curl -X GET http://schema.registry.url:8888/subjects/{topic}/versions/

String command = "curl -X GET --header 'Accept: application/vnd.schemaregistry.v1+json' 'https://schema.registry.url:8888/api/schema-proxy/subjects/mytopic-value/versions'";
Process process = Runtime.getRuntime().exec(command);

Reader reader = new InputStreamReader(process.getInputStream());
int result;
while ((result = reader.read()) != -1){ // Nothing printed
    System.out.println(result);
}

我如何修复这个GET请求，或者更好的是，我应该如何使用模式注册中心客户端来检索一个模式？

Answer 1

用以下方法得出结论：

SchemaMetadata sm = client.getLatestSchemaMetadata(schemaName);
System.out.println(sm.getSchema());