public EndpointResponse get() {
    return EndpointResponse.ok(new ServerInfo(
        appVersion.get(),
        kafkaClusterId.get(),
        ksqlServiceId.get(),
        serverStatus.get().toString()));
  }
@Test
  public void shouldReturnServerInfo() {
    // When:
    final EndpointResponse response = serverInfoResource.get();

    // Then:
    assertThat(response.getStatus(), equalTo(200));
    assertThat(response.getEntity(), instanceOf(ServerInfo.class));
    final ServerInfo serverInfo = (ServerInfo)response.getEntity();
    assertThat(
        serverInfo,
        equalTo(new ServerInfo(AppInfo.getVersion(), KAFKA_CLUSTER_ID, KSQL_SERVICE_ID, "RUNNING"))
    );
  }