Fix memory leak (#35)

jcustenborder · Jul 7, 2021 · 98af161 · 98af161
1 parent 252c416
commit 98af161
Showing 1 changed file with 1 addition and 0 deletions.
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
@@ -178,6 +178,7 @@ public static RedisSessionImpl create(RedisConnectorConfig config) {
     @Override
     public void close() throws Exception {
       this.connection.close();
+      this.client.shutdown();
     }
   }
 }