From: Kate Hsuan <kate.hsuan@qct.io>
Date: Thu, 16 May 2019 01:55:47 +0000 (+0800)
Subject: Bug fix
X-Git-Tag: 2.0.0~135
X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=befe1a885cbe2d9a89ed3d225fb2e90db692c50b;p=dcaegen2%2Fservices.git

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 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);