diff --git a/service/commons/elasticsearch/client-api/src/main/java/org/eclipse/kapua/service/elasticsearch/client/AbstractElasticsearchClient.java b/service/commons/elasticsearch/client-api/src/main/java/org/eclipse/kapua/service/elasticsearch/client/AbstractElasticsearchClient.java
index aa51d64b74b..c524e591f56 100644
--- a/service/commons/elasticsearch/client-api/src/main/java/org/eclipse/kapua/service/elasticsearch/client/AbstractElasticsearchClient.java
+++ b/service/commons/elasticsearch/client-api/src/main/java/org/eclipse/kapua/service/elasticsearch/client/AbstractElasticsearchClient.java
@@ -25,7 +25,7 @@ public abstract class AbstractElasticsearchClient<C extends Closeable> implement
 
     protected String clientType;
 
-    private C client;
+    protected C client;
 
     private ElasticsearchClientConfiguration clientConfiguration;
     private ModelContext modelContext;
diff --git a/service/commons/elasticsearch/client-rest/src/main/java/org/eclipse/kapua/service/elasticsearch/client/rest/RestElasticsearchClient.java b/service/commons/elasticsearch/client-rest/src/main/java/org/eclipse/kapua/service/elasticsearch/client/rest/RestElasticsearchClient.java
index a8d20fb1597..d22a748e681 100644
--- a/service/commons/elasticsearch/client-rest/src/main/java/org/eclipse/kapua/service/elasticsearch/client/rest/RestElasticsearchClient.java
+++ b/service/commons/elasticsearch/client-rest/src/main/java/org/eclipse/kapua/service/elasticsearch/client/rest/RestElasticsearchClient.java
@@ -118,7 +118,13 @@ public void init() throws ClientInitializationException {
 
     @Override
     public void close() {
-        // No resources to close
+        if(client != null) {
+            try {
+                client.close();
+            } catch (IOException e) {
+                LOG.error("Error closing client", e);
+            }
+        }
     }
 
     @Override