diff --git a/modbus-tcp/src/main/java/com/digitalpetri/modbus/tcp/client/NettyRtuClientTransport.java b/modbus-tcp/src/main/java/com/digitalpetri/modbus/tcp/client/NettyRtuClientTransport.java
index 5fd8966..3a324cc 100644
--- a/modbus-tcp/src/main/java/com/digitalpetri/modbus/tcp/client/NettyRtuClientTransport.java
+++ b/modbus-tcp/src/main/java/com/digitalpetri/modbus/tcp/client/NettyRtuClientTransport.java
@@ -26,6 +26,7 @@
 import io.netty.handler.ssl.SslContext;
 import io.netty.handler.ssl.SslContextBuilder;
 import io.netty.handler.ssl.SslProtocols;
+import java.net.InetSocketAddress;
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.CompletionStage;
@@ -248,7 +249,7 @@ protected void initChannel(SocketChannel channel) throws Exception {
       var future = new CompletableFuture<Channel>();
 
       bootstrap
-          .connect(config.hostname(), config.port())
+          .connect(new InetSocketAddress(config.hostname(), config.port()))
           .addListener(
               (ChannelFutureListener)
                   channelFuture -> {
diff --git a/modbus-tcp/src/main/java/com/digitalpetri/modbus/tcp/client/NettyTcpClientTransport.java b/modbus-tcp/src/main/java/com/digitalpetri/modbus/tcp/client/NettyTcpClientTransport.java
index e91fa49..c9e9e66 100644
--- a/modbus-tcp/src/main/java/com/digitalpetri/modbus/tcp/client/NettyTcpClientTransport.java
+++ b/modbus-tcp/src/main/java/com/digitalpetri/modbus/tcp/client/NettyTcpClientTransport.java
@@ -21,6 +21,7 @@
 import io.netty.handler.ssl.SslContextBuilder;
 import io.netty.handler.ssl.SslHandler;
 import io.netty.handler.ssl.SslProtocols;
+import java.net.InetSocketAddress;
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.CompletionStage;
@@ -195,7 +196,7 @@ public CompletableFuture<Channel> connect(FsmContext<State, Event> fsmContext) {
       var future = new CompletableFuture<Channel>();
 
       bootstrap
-          .connect(config.hostname(), config.port())
+          .connect(new InetSocketAddress(config.hostname(), config.port()))
           .addListener(
               (ChannelFutureListener)
                   channelFuture -> {