@Test public void testGetTopLevelConfig() { try { Config config = mock(Config.class); ResponseEntity entity = mock(ResponseEntity.class); when(service.restTemplate.getForEntity( "${kafka.schema.registry.url}/config", Config.class)).thenReturn(entity); when(entity.getBody()).thenReturn(config); service.getTopLevelConfig(); assertTrue(true); } catch (Throwable t) { fail("Cannot get all tables from all dbs"); } }
@Override public Config getTopLevelConfig() { String path = "/config"; String regUrl = registryUrl(path); ResponseEntity<Config> res = restTemplate.getForEntity(regUrl, Config.class); Config result = res.getBody(); return result; }
KafkaSchemaServiceImpl implements KafkaSchemaService { @Override public Config getTopLevelConfig() { String path = "/config"; String regUrl = registryUrl(path); ResponseEntity<Config> res = restTemplate.getForEntity(regUrl, Config.class); Config result = res.getBody(); return result; } }
KafkaSchemaServiceImpl implements KafkaSchemaService { @Override public Config getTopLevelConfig() { String path = "/config"; String regUrl = registryUrl(path); ResponseEntity<Config> res = restTemplate.getForEntity(regUrl, Config.class); Config result = res.getBody(); return result; }  }
KafkaSchemaServiceImpl implements KafkaSchemaService { @Override public Config getTopLevelConfig() { String path = "/config"; String regUrl = registryUrl(path); ResponseEntity<Config> res = restTemplate.getForEntity(regUrl, Config.class); Config result = res.getBody(); return result; }  @Override SchemaString getSchemaString(Integer id); @Override Iterable<String> getSubjects(); @Override Iterable<Integer> getSubjectVersions(String subject); @Override Schema getSubjectSchema(String subject, String version); @Override Config getTopLevelConfig(); @Override Config getSubjectLevelConfig(String subject); }
KafkaSchemaServiceImpl implements KafkaSchemaService { @Override public Config getTopLevelConfig() { String path = "/config"; String regUrl = registryUrl(path); ResponseEntity<Config> res = restTemplate.getForEntity(regUrl, Config.class); Config result = res.getBody(); return result; }  @Override SchemaString getSchemaString(Integer id); @Override Iterable<String> getSubjects(); @Override Iterable<Integer> getSubjectVersions(String subject); @Override Schema getSubjectSchema(String subject, String version); @Override Config getTopLevelConfig(); @Override Config getSubjectLevelConfig(String subject);  }