| commit | 8e9eeef523ac300106c70441821c7eb7bbd77beb | [log] [tgz] |
|---|---|---|
| author | Andy Bavier <andy@onlab.us> | Wed Sep 19 15:40:58 2018 -0700 |
| committer | Andy Bavier <andy@onlab.us> | Wed Sep 19 15:41:07 2018 -0700 |
| tree | 86facb8355ad235ed35505e3c5685954b0658c59 | |
| parent | e53b12a952586fedd7b1301d3cc90c535b95557b [diff] |
SEBA-263 Pick up pre-loaded config to create kafkaProducer Change-Id: Ib74ea04e391144682bd5f743a4facae11de3d502
diff --git a/src/main/java/org/opencord/kafka/impl/KafkaIntegration.java b/src/main/java/org/opencord/kafka/impl/KafkaIntegration.java index bfc5ec9..3610d50 100644 --- a/src/main/java/org/opencord/kafka/impl/KafkaIntegration.java +++ b/src/main/java/org/opencord/kafka/impl/KafkaIntegration.java
@@ -107,6 +107,7 @@ appId = coreService.registerApplication(APP_NAME); configRegistry.registerConfigFactory(kafkaConfigFactory); configRegistry.addListener(configListener); + configure(); log.info("Started"); }