2 files changed, 16 insertions, 1 deletions

diff --git a/sdc-distribution-client/src/main/java/org/onap/sdc/utils/kafka/SdcKafkaConsumer.java b/sdc-distribution-client/src/main/java/org/onap/sdc/utils/kafka/SdcKafkaConsumer.java
index 71f793d..91b41a9 100644
--- a/sdc-distribution-client/src/main/java/org/onap/sdc/utils/kafka/SdcKafkaConsumer.java
+++ b/sdc-distribution-client/src/main/java/org/onap/sdc/utils/kafka/SdcKafkaConsumer.java
@@ -94,6 +94,10 @@ public class SdcKafkaConsumer {
         return msgs;
     }
 
+    /**
+     *
+     * @return The topic being polled by the consumer
+     */
     public String getTopicName() {
         return topicName;
     }
diff --git a/sdc-distribution-client/src/main/java/org/onap/sdc/utils/kafka/SdcKafkaProducer.java b/sdc-distribution-client/src/main/java/org/onap/sdc/utils/kafka/SdcKafkaProducer.java
index 9826f8b..19338fc 100644
--- a/sdc-distribution-client/src/main/java/org/onap/sdc/utils/kafka/SdcKafkaProducer.java
+++ b/sdc-distribution-client/src/main/java/org/onap/sdc/utils/kafka/SdcKafkaProducer.java
@@ -45,6 +45,10 @@ public class SdcKafkaProducer {
     private final List<String> msgBusAddresses;
     private final String topicName;
 
+    /**
+     *
+     * @param configuration The config provided to the client
+     */
     public SdcKafkaProducer(Configuration configuration) {
         Properties props = new Properties();
         props.put(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, configuration.getMsgBusAddress());
@@ -76,8 +80,9 @@ public class SdcKafkaProducer {
         }
         return data;
     }
+
     /**
-     *
+     * Flush accumulated records in producer
      */
     public void flush() {
         try {
@@ -88,10 +93,16 @@ public class SdcKafkaProducer {
         }
     }
 
+    /**
+     * @return The list kafka endpoints
+     */
     public List<String> getMsgBusAddresses() {
         return msgBusAddresses;
     }
 
+    /**
+     * @return The topic name being published to
+     */
     public String getTopicName() {
         return topicName;
     }