| commit | 7ad7de9433a736bf154b00a9c44a5f0862728bf1 | [log] [tgz] |
|---|---|---|
| author | Saurav Das <sauravdas@alumni.stanford.edu> | Wed Oct 17 22:57:02 2018 +0000 |
| committer | Gerrit Code Review <gerrit@opencord.org> | Wed Oct 17 22:57:02 2018 +0000 |
| tree | 61aac33465cc38e66c929ccb031d549c2085f347 | |
| parent | adc1e967dcebc2e9b16714176345e4f53d3e5939 [diff] | |
| parent | 8e9eeef523ac300106c70441821c7eb7bbd77beb [diff] |
Merge "SEBA-263 Pick up pre-loaded config to create kafkaProducer"
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"); }