diff options
Diffstat (limited to 'sdc-distribution-client/src/main/java/org/onap/sdc/utils')
-rw-r--r-- | sdc-distribution-client/src/main/java/org/onap/sdc/utils/kafka/SdcKafkaConsumer.java | 4 | ||||
-rw-r--r-- | sdc-distribution-client/src/main/java/org/onap/sdc/utils/kafka/SdcKafkaProducer.java | 13 |
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; } |