public HealthCheckResponse checkHealth() {
    final Map<String, HealthCheckResponseDetail> results = DEFAULT_CHECKS.stream()
        .collect(Collectors.toMap(
            Check::getName,
            check -> check.check(this)
        ));
    final boolean allHealthy = results.values().stream()
        .allMatch(HealthCheckResponseDetail::getIsHealthy);
    final State serverState = commandRunner.checkServerState();
    return new HealthCheckResponse(allHealthy, results, Optional.of(serverState.toString()));
  }
@Test
  public void shouldReturnHealthyIfKafkaCheckFailsWithUnknownTopicOrPartitionException() {
    // Given:
    givenDescribeTopicsThrows(new UnknownTopicOrPartitionException());

    // When:
    final HealthCheckResponse response = healthCheckAgent.checkHealth();

    // Then:
    assertThat(response.getDetails().get(KAFKA_CHECK_NAME).getIsHealthy(), is(true));
    assertThat(response.getIsHealthy(), is(true));
  }