From 98af161269777c4ff87fb0613a9fb1b9ff7f2143 Mon Sep 17 00:00:00 2001
From: conwayok <32290192+conwayok@users.noreply.github.com>
Date: Wed, 7 Jul 2021 23:29:29 +0800
Subject: [PATCH] Fix memory leak (#35)

---
 .../kafka/connect/redis/RedisSessionFactoryImpl.java             | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/redis/RedisSessionFactoryImpl.java b/src/main/java/com/github/jcustenborder/kafka/connect/redis/RedisSessionFactoryImpl.java
index b61dd6b..aed1853 100644
--- a/src/main/java/com/github/jcustenborder/kafka/connect/redis/RedisSessionFactoryImpl.java
+++ b/src/main/java/com/github/jcustenborder/kafka/connect/redis/RedisSessionFactoryImpl.java
@@ -178,6 +178,7 @@ public static RedisSessionImpl create(RedisConnectorConfig config) {
     @Override
     public void close() throws Exception {
       this.connection.close();
+      this.client.shutdown();
     }
   }
 }