commit | befe1a885cbe2d9a89ed3d225fb2e90db692c50b | [log] [tgz] |
---|---|---|
author | Kate Hsuan <kate.hsuan@qct.io> | Thu May 16 09:55:47 2019 +0800 |
committer | Kate Hsuan <kate.hsuan@qct.io> | Thu May 16 09:55:47 2019 +0800 |
tree | 09d9c8a27c958b4ae5f4dd3a67263f4d59064b89 | |
parent | 0b87803e495ac8a0c926b985617cd8994eadea58 [diff] |
Bug fix 1. Close zookeeper connection. Issue-ID: DCAEGEN2-1437 Change-Id: I7a2bfdcf14203cbe1708e6148b12ea00c49a07a1 Signed-off-by: Kate Hsuan <kate.hsuan@qct.io>
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 0caec79..02aa626 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 @@ 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);