diff options
Diffstat (limited to 'components/datalake-handler/feeder/src/main/java/org')
| -rw-r--r-- | components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/DmaapService.java | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/DmaapService.java b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/DmaapService.java index 0caec79a..02aa6264 100644 --- a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/DmaapService.java +++ b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/DmaapService.java @@ -67,6 +67,7 @@ public class DmaapService { List<String> topics = zk.getChildren("/brokers/topics", false); String[] excludes = config.getDmaapKafkaExclude(); topics.removeAll(Arrays.asList(excludes)); + zk.close(); return topics; } catch (Exception e) { log.error("Can not get topic list from Zookeeper, for testing, going to use hard coded topic list.", e); |