From befe1a885cbe2d9a89ed3d225fb2e90db692c50b Mon Sep 17 00:00:00 2001 From: Kate Hsuan Date: Thu, 16 May 2019 09:55:47 +0800 Subject: Bug fix 1. Close zookeeper connection. Issue-ID: DCAEGEN2-1437 Change-Id: I7a2bfdcf14203cbe1708e6148b12ea00c49a07a1 Signed-off-by: Kate Hsuan --- .../src/main/java/org/onap/datalake/feeder/service/DmaapService.java | 1 + 1 file changed, 1 insertion(+) (limited to 'components/datalake-handler/feeder/src/main/java/org') 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 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); -- cgit 1.2.3-korg