diff --git a/pom.xml b/pom.xml
index dc278d7d..2ea0d104 100644
--- a/pom.xml
+++ b/pom.xml
@@ -105,7 +105,7 @@
     <snappy.version>1.1.10.8</snappy.version>
     <spotbugs.annotations.version>4.9.3</spotbugs.annotations.version>
     <typesafe.config.version>1.4.4</typesafe.config.version>
-    <vertx.core.version>4.5.14</vertx.core.version>
+    <vertx.core.version>5.0.1</vertx.core.version>
 
     <!--Test dependency versions-->
     <commons.math3.version>3.6.1</commons.math3.version>
@@ -535,6 +535,19 @@
     </plugins>
   </build>
 
+  <dependencyManagement>
+    <dependencies>
+      <!-- Force Netty version to be compatible with Vert.x 5.x -->
+      <dependency>
+        <groupId>io.netty</groupId>
+        <artifactId>netty-bom</artifactId>
+        <version>4.2.2.Final</version>
+        <type>pom</type>
+        <scope>import</scope>
+      </dependency>
+    </dependencies>
+  </dependencyManagement>
+
   <dependencies>
     <!-- Logging -->
     <dependency>
diff --git a/src/main/java/com/arpnetworking/tsdcore/sinks/VertxSink.java b/src/main/java/com/arpnetworking/tsdcore/sinks/VertxSink.java
index 36ec6795..325bf6ee 100644
--- a/src/main/java/com/arpnetworking/tsdcore/sinks/VertxSink.java
+++ b/src/main/java/com/arpnetworking/tsdcore/sinks/VertxSink.java
@@ -222,10 +222,8 @@ private void connectToServer() {
                 .addData("port", _serverPort)
                 .log();
         _lastConnectionAttempt = currentTime;
-        _client.connect(
-                _serverPort,
-                resolvedHostname,
-                new ConnectionHandler(resolvedHostname));
+        _client.connect(_serverPort, resolvedHostname)
+                .onComplete(new ConnectionHandler(resolvedHostname));
     }
 
     private Handler<Void> createSocketCloseHandler(final NetSocket socket) {