diff --git a/pom.xml b/pom.xml index 82757b0..80c3bb9 100644 --- a/pom.xml +++ b/pom.xml @@ -8,7 +8,7 @@ war UTF-8 - 0.10.1 + 0.10.2 2.24.1 3.8.0 3.1.8 diff --git a/src/main/java/io/rtdi/bigdata/rulesservice/RulesService.java b/src/main/java/io/rtdi/bigdata/rulesservice/RulesService.java index a9f358f..1ace2d0 100644 --- a/src/main/java/io/rtdi/bigdata/rulesservice/RulesService.java +++ b/src/main/java/io/rtdi/bigdata/rulesservice/RulesService.java @@ -529,6 +529,7 @@ private void close() { } catch (Exception e) { LoggingUtil.LOGGER.error("Closing the Kafka admin client within 10 seconds failed - ignored", e); } + admin = null; } if (schemaclient != null) { try { @@ -536,6 +537,7 @@ private void close() { } catch (Exception e) { LoggingUtil.LOGGER.error("Closing the schema registry client failed - ignored", e); } + schemaclient = null; } }