ApiController.java 文件源码

/**
 * GET Details for a specific Topic.
 */
@ResponseBody
@RequestMapping(path = "/cluster/{id}/topic/{topic}/details", method = RequestMethod.GET, produces = "application/json")
public TopicDetails getTopicDetails(@PathVariable final Long id, @PathVariable final String topic) {
    // Retrieve cluster
    final Cluster cluster = clusterRepository.findOne(id);
    if (cluster == null) {
        throw new NotFoundApiException("TopicDetails", "Unable to find cluster");
    }

    // Create new Operational Client
    try (final KafkaOperations operations = createOperationsClient(cluster)) {
        return operations.getTopicDetails(topic);
    } catch (final Exception e) {
        throw new ApiException("TopicDetails", e);
    }
}