public EndpointResponse get() {
    return EndpointResponse.ok(new ServerInfo(
        appVersion.get(),
        kafkaClusterId.get(),
        ksqlServiceId.get(),
        serverStatus.get().toString()));
  }
@Test
  public void shouldGetKafkaClusterIdWithTimeout()
      throws InterruptedException, ExecutionException, TimeoutException{
    // When:
    serverInfoResource.get();

    // Then:
    verify(future).get(30, TimeUnit.SECONDS);
  }