public Health health()

in src/main/java/com/epam/digital/data/platform/starter/actuator/readinessprobe/KafkaHealthIndicator.java [42:53]

• 12 lines of code
• 2 McCabe index (conditional complexity)

  public Health health() {
    try {
      kafkaTemplate.send(KAFKA_HEALTH_TOPIC, KAFKA_HEALTH_MESSAGE)
          .get(RESPONSE_TIMEOUT, TimeUnit.MILLISECONDS);
    } catch (Exception e) {
      log.error("KafkaHealthIndicator failed", e);
      return Health.down()
              .withException(e)
              .build();
    }
    return Health.up().build();
  }