Fix memory leak (#35)

conwayok · web-flow · commit 98af16126977 · 2021-07-07T10:29:29.000-05:00
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();
     }
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -178,6 +178,7 @@ public static RedisSessionImpl create(RedisConnectorConfig config) {`
`178`	`178`	`@Override`
`179`	`179`	`public void close() throws Exception {`
`180`	`180`	`this.connection.close();`
	`181`	`+ this.client.shutdown();`
`181`	`182`	`}`
`182`	`183`	`}`
`183`	`184`	`}`