private Collection getConfiguredHealthTopics()

in src/main/java/com/epam/digital/data/platform/starter/actuator/readinessprobe/KafkaHealthCheckTopicCreator.java [89:93]

• 5 lines of code
• 1 McCabe index (conditional complexity)

  private Collection<NewTopic> getConfiguredHealthTopics() {
    var newTopic = new NewTopic(KAFKA_HEALTH_TOPIC, NUM_PARTITIONS, REPLICATION_FACTOR);
    newTopic.configs(Map.of(RETENTION_MS_CONFIG, Long.toString(RETENTION_MS)));
    return Collections.singleton(newTopic);
  }