[KAFKA] Allow kafka params to be passed as config

Allow topic names to be passed
Add new api endpoint to retrieve the kafka and topic info

Signed-off-by: efiacor <fiachra.corcoran@est.tech>
Issue-ID: DMAAP-1744
Change-Id: Id7bdcf54c6191a5953bc94092218595bf608a733

1 files changed, 9 insertions, 0 deletions

diff --git a/common-app-api/src/main/java/org/openecomp/sdc/be/config/DistributionEngineConfiguration.java b/common-app-api/src/main/java/org/openecomp/sdc/be/config/DistributionEngineConfiguration.java
index 834d7cb579..205588adab 100644
--- a/common-app-api/src/main/java/org/openecomp/sdc/be/config/DistributionEngineConfiguration.java
+++ b/common-app-api/src/main/java/org/openecomp/sdc/be/config/DistributionEngineConfiguration.java
@@ -32,6 +32,7 @@ public class DistributionEngineConfiguration extends BasicConfiguration {
     private List<String> uebServers;
     private String distributionNotifTopicName;
     private String distributionStatusTopicName;
+    private String kafkaBootStrapServers;
     private Integer initRetryIntervalSec;
     private Integer initMaxIntervalSec;
     private ComponentArtifactTypesConfig distribNotifServiceArtifactTypes;
@@ -75,6 +76,14 @@ public class DistributionEngineConfiguration extends BasicConfiguration {
         this.distributionStatusTopicName = distributionStatusTopicName;
     }
 
+    public String getKafkaBootStrapServers() {
+        return kafkaBootStrapServers;
+    }
+
+    public void setKafkaBootStrapServers(String kafkaBootStrapServers) {
+        this.kafkaBootStrapServers = kafkaBootStrapServers;
+    }
+
     public Integer getInitRetryIntervalSec() {
         return initRetryIntervalSec;
     }