diff --git a/internal/pkg/afrouter/connection.go b/internal/pkg/afrouter/connection.go
index dcdb8d6..fc1c057 100644
--- a/internal/pkg/afrouter/connection.go
+++ b/internal/pkg/afrouter/connection.go
@@ -41,7 +41,7 @@
 		// Check back later to confirm and increase the connection count.
 
 		var err error
-		conn, err := grpc.Dial(cn.addr+":"+cn.port, grpc.WithCodec(Codec()), grpc.WithInsecure(), grpc.WithBackoffMaxDelay(time.Second*15))
+		conn, err := grpc.Dial(cn.addr+":"+cn.port, grpc.WithDefaultCallOptions(grpc.ForceCodec(Codec())), grpc.WithInsecure(), grpc.WithBackoffMaxDelay(time.Second*15))
 		if err != nil {
 			log.Fatalf("Dialing connection %v:%v", cn, err)
 		}