diff --git a/src/test/java/io/vertx/mqtt/it/MqttClientConnectIT.java b/src/test/java/io/vertx/mqtt/it/MqttClientConnectIT.java
index 778d0a1a..07fc1a69 100644
--- a/src/test/java/io/vertx/mqtt/it/MqttClientConnectIT.java
+++ b/src/test/java/io/vertx/mqtt/it/MqttClientConnectIT.java
@@ -119,6 +119,9 @@ public void connackNotOk(TestContext context) {
         MqttConnectionException connEx = (MqttConnectionException) err;
         assertEquals(connEx.code(), MqttConnectReturnCode.CONNECTION_REFUSED_SERVER_UNAVAILABLE);
         assertFalse(client.isConnected());
+        // Ensure server and Vertx are closed
+        server.close().onComplete(context.asyncAssertSuccess());
+        vertx.close();
       }));
   }
 }