From 6c60c2b0a9ef5621b408e7a9b8514edd34bc23ee Mon Sep 17 00:00:00 2001 From: werner daehn Date: Mon, 12 May 2025 09:58:55 +0200 Subject: [PATCH] error handling --- pom.xml | 2 +- src/main/java/io/rtdi/bigdata/rulesservice/RulesService.java | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) 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; } }