1 files changed, 7 insertions, 3 deletions
diff --git a/datacollector/src/main/java/org/onap/rapp/datacollector/service/configuration/DmaapProperties.java b/datacollector/src/main/java/org/onap/rapp/datacollector/service/configuration/DmaapProperties.java
index 3560e89..a664e8e 100644
--- a/datacollector/src/main/java/org/onap/rapp/datacollector/service/configuration/DmaapProperties.java
+++ b/datacollector/src/main/java/org/onap/rapp/datacollector/service/configuration/DmaapProperties.java
@@ -13,6 +13,9 @@
 
 package org.onap.rapp.datacollector.service.configuration;
 
+import java.util.ArrayList;
+import java.util.List;
+import java.util.stream.Collectors;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 
 import lombok.Getter;
@@ -28,10 +31,11 @@ public class DmaapProperties {
     private String username;
     private String password;
     private int port;
-    private String measurementsTopic;
+    private List<String> measurementsTopics = new ArrayList<>();
 
-    public String getMeasurementsTopicUrl() {
-        return String.format("%s://%s:%d/%s", protocol, host, port, measurementsTopic);
+    public List<String> getMeasurementsTopicUrls() {
+        return measurementsTopics.stream().map(topic -> String.format("%s://%s:%d/%s", protocol, host, port, topic))
+                .collect(Collectors.toList());
     }
 
 }