Add support for graceful shutdown (#1030)

* Shutdown gracefully http server

Signed-off-by: Marc Lallaouret <[email protected]>

* Feedback from strimzi maintainer

Signed-off-by: Marc Lallaouret <[email protected]>

---------

Signed-off-by: Marc Lallaouret <[email protected]>

Author: mlallaouret

src/main/java/io/strimzi/kafka/bridge/Application.java

@@ -85,6 +85,19 @@ private static Future<HttpBridge> deployHttpBridge(BridgeConfig bridgeConfig)
         vertx.deployVerticle(httpBridge)
                 .onSuccess(deploymentId -> {
                     LOGGER.info("HTTP verticle instance [{}] deployed", deploymentId);
+
+                    // Register shutdown hook for graceful shutdown
+                    Runtime.getRuntime().addShutdownHook(new Thread(() -> {
+                        LOGGER.info("Shutdown hook triggered, starting graceful shutdown...");
+                        vertx.close()
+                                .onComplete(ar -> {
+                                    if (ar.succeeded()) {
+                                        LOGGER.info("Vertx instance closed successfully");
+                                    } else {
+                                        LOGGER.error("Error closing Vertx instance", ar.cause());
+                                    }
+                                });
+                    }));
                     httpPromise.complete(httpBridge);
                 })
                 .onFailure(t -> {

src/main/java/io/strimzi/kafka/bridge/http/HttpBridge.java

@@ -305,7 +305,7 @@ public void stop(Promise<Void> stopPromise) {
 
         if (this.httpServer != null) {
 
-            this.httpServer.close()
+            this.httpServer.shutdown()
                     .onSuccess(v -> {
                         LOGGER.info("HTTP-Kafka bridge has been shut down successfully");
                         stopPromise.complete();