@Test public void test_getSubjectVersions() throws Exception { String subject = "s-1"; when(kafkaSchemaService.getSubjectVersions(subject)).thenReturn(Arrays .asList(1, 2, 3)); mockMvc.perform(get(API_PATH + "/versions") .param("subject", subject)) .andExpect(status().isOk()); verify(kafkaSchemaService).getSubjectVersions(subject); }
@RequestMapping(value = "/versions", method = RequestMethod.GET) public Iterable<Integer> getSubjectVersions( @RequestParam("subject") String subject) { return kafkaSchemaService.getSubjectVersions(subject); }
KafkaSchemaController { @RequestMapping(value = "/versions", method = RequestMethod.GET) public Iterable<Integer> getSubjectVersions( @RequestParam("subject") String subject) { return kafkaSchemaService.getSubjectVersions(subject); } }
KafkaSchemaController { @RequestMapping(value = "/versions", method = RequestMethod.GET) public Iterable<Integer> getSubjectVersions( @RequestParam("subject") String subject) { return kafkaSchemaService.getSubjectVersions(subject); }  }
KafkaSchemaController { @RequestMapping(value = "/versions", method = RequestMethod.GET) public Iterable<Integer> getSubjectVersions( @RequestParam("subject") String subject) { return kafkaSchemaService.getSubjectVersions(subject); }  @RequestMapping(value = "/schema/{id}", method = RequestMethod.GET) SchemaString getSchemaString(@PathVariable("id") Integer id); @RequestMapping(value = "/subject", method = RequestMethod.GET) Iterable<String> getSubjects(); @RequestMapping(value = "/versions", method = RequestMethod.GET) Iterable<Integer> getSubjectVersions(
        @RequestParam("subject") String subject); @RequestMapping(value = "/subjectSchema", method = RequestMethod.GET) Schema getSubjectSchema(@RequestParam("subject") String subject,
                                   @RequestParam("version") String version); @RequestMapping(value = "/config", method = RequestMethod.GET) Config getTopLevelConfig(); @RequestMapping(value = "/config/{subject}", method = RequestMethod.GET) Config getSubjectLevelConfig(@PathVariable("subject") String subject); }
KafkaSchemaController { @RequestMapping(value = "/versions", method = RequestMethod.GET) public Iterable<Integer> getSubjectVersions( @RequestParam("subject") String subject) { return kafkaSchemaService.getSubjectVersions(subject); }  @RequestMapping(value = "/schema/{id}", method = RequestMethod.GET) SchemaString getSchemaString(@PathVariable("id") Integer id); @RequestMapping(value = "/subject", method = RequestMethod.GET) Iterable<String> getSubjects(); @RequestMapping(value = "/versions", method = RequestMethod.GET) Iterable<Integer> getSubjectVersions(
        @RequestParam("subject") String subject); @RequestMapping(value = "/subjectSchema", method = RequestMethod.GET) Schema getSubjectSchema(@RequestParam("subject") String subject,
                                   @RequestParam("version") String version); @RequestMapping(value = "/config", method = RequestMethod.GET) Config getTopLevelConfig(); @RequestMapping(value = "/config/{subject}", method = RequestMethod.GET) Config getSubjectLevelConfig(@PathVariable("subject") String subject);  }