@Test (expected = RestClientException.class) public void testGetWrongSchemaIdVersions() throws Exception { client.getVersions("c0", "foo1"); }
public List<Long> getVersions(String namespace, String id) throws URISyntaxException, IOException, RestClientException { URL url = concat(new URI(baseUrl), String.format("contexts/%s/schemas/%s/versions", namespace, id)).toURL(); Response<Long> response = request(url, "GET", new TypeToken<Response<Long>>() { }.getType()); return response.getValues(); }
SchemaRegistryClient { public List<Long> getVersions(String namespace, String id) throws URISyntaxException, IOException, RestClientException { URL url = concat(new URI(baseUrl), String.format("contexts/%s/schemas/%s/versions", namespace, id)).toURL(); Response<Long> response = request(url, "GET", new TypeToken<Response<Long>>() { }.getType()); return response.getValues(); } }
SchemaRegistryClient { public List<Long> getVersions(String namespace, String id) throws URISyntaxException, IOException, RestClientException { URL url = concat(new URI(baseUrl), String.format("contexts/%s/schemas/%s/versions", namespace, id)).toURL(); Response<Long> response = request(url, "GET", new TypeToken<Response<Long>>() { }.getType()); return response.getValues(); } SchemaRegistryClient(String baseUrl); }
SchemaRegistryClient { public List<Long> getVersions(String namespace, String id) throws URISyntaxException, IOException, RestClientException { URL url = concat(new URI(baseUrl), String.format("contexts/%s/schemas/%s/versions", namespace, id)).toURL(); Response<Long> response = request(url, "GET", new TypeToken<Response<Long>>() { }.getType()); return response.getValues(); } SchemaRegistryClient(String baseUrl); static SchemaRegistryClient getInstance(ExecutorContext context); byte[] getSchema(String namespace, String id, long version); byte[] getSchema(String namespace, String id); List<Long> getVersions(String namespace, String id); String getBaseUrl(); String getAcceptEncoding(); void setAcceptEncoding(String acceptEncoding); int getConnectionTimeout(); void setConnectionTimeout(int connectionTimeout); int getReadTimeout(); void setReadTimeout(int readTimeout); }
SchemaRegistryClient { public List<Long> getVersions(String namespace, String id) throws URISyntaxException, IOException, RestClientException { URL url = concat(new URI(baseUrl), String.format("contexts/%s/schemas/%s/versions", namespace, id)).toURL(); Response<Long> response = request(url, "GET", new TypeToken<Response<Long>>() { }.getType()); return response.getValues(); } SchemaRegistryClient(String baseUrl); static SchemaRegistryClient getInstance(ExecutorContext context); byte[] getSchema(String namespace, String id, long version); byte[] getSchema(String namespace, String id); List<Long> getVersions(String namespace, String id); String getBaseUrl(); String getAcceptEncoding(); void setAcceptEncoding(String acceptEncoding); int getConnectionTimeout(); void setConnectionTimeout(int connectionTimeout); int getReadTimeout(); void setReadTimeout(int readTimeout);  }