private Map getRetentionPolicy()

in src/main/java/com/epam/digital/data/platform/starter/restapi/service/StartupKafkaTopicsCreator.java [121:131]

• 8 lines of code
• 3 McCabe index (conditional complexity)

  private Map<String, String> getRetentionPolicy(String topicName) {

    var retentionPolicyInDays = kafkaProperties.getTopicProperties().getRetentionPolicyInDays();

    int days = retentionPolicyInDays.getWrite();
    if (topicName.startsWith(READ) || topicName.startsWith(SEARCH)) {
      days = retentionPolicyInDays.getRead();
    }

    return Map.of(RETENTION_MS_CONFIG, Long.toString(days * DAYS_TO_MS));
  }