Merge pull request #24 from CDOT-CV/bug/deposit-topic-override

Subscription topic override bug fix

pom.xml

@@ -108,6 +108,9 @@
                   <loader.path>${loader.path}</loader.path>
                   <buildDirectory>${project.build.directory}</buildDirectory>
                </systemPropertyVariables>
+               <environmentVariables>
+                  <SDW_SUBSCRIPTION_TOPIC>testSubscriptionTopic</SDW_SUBSCRIPTION_TOPIC>
+                </environmentVariables>
             </configuration>
             <dependencies>
                <dependency>

src/main/java/jpo/sdw/depositor/DepositorProperties.java

@@ -2,8 +2,6 @@
 
 import java.util.regex.Pattern;
 
-import jakarta.annotation.PostConstruct;
-
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -12,6 +10,8 @@
 import org.springframework.context.annotation.PropertySource;
 import org.springframework.core.env.Environment;
 
+import jakarta.annotation.PostConstruct;
+
 @ConfigurationProperties("sdw")
 @PropertySource("classpath:application.properties")
 public class DepositorProperties implements EnvironmentAware {
@@ -66,9 +66,15 @@ void initialize() {
       }
 
       if (getSubscriptionTopics() == null || getSubscriptionTopics().length == 0) {
-         String topics = String.join(",", DEFAULT_SUBSCRIPTION_TOPICS);
-         logger.info("No Kafka subscription topics specified in configuration, defaulting to {}", topics);
-         subscriptionTopics = DEFAULT_SUBSCRIPTION_TOPICS;
+         // get environment variable SDW_SUBSCRIPTION_TOPIC
+         String topics = System.getenv("SDW_SUBSCRIPTION_TOPIC");
+         if (topics == null || topics.isEmpty()) {
+            topics = String.join(",", DEFAULT_SUBSCRIPTION_TOPICS);
+            logger.info("No Kafka subscription topics specified in configuration, defaulting to {}", topics);
+            subscriptionTopics = DEFAULT_SUBSCRIPTION_TOPICS;
+         } else {
+            subscriptionTopics = topics.split(",");
+         }
       }
 
       if (getApiKey() == null || getApiKey().isEmpty()) {