solution: revise for the latest etherjar

src/main/kotlin/io/emeraldpay/dshackle/upstream/ConfiguredUpstreams.kt

@@ -132,13 +132,14 @@ open class ConfiguredUpstreams(
         }
         conn.rpc?.let { endpoint ->
             val rpcClient = ReactorHttpRpcClient.newBuilder()
-                    .setTarget(endpoint.url)
+                    .connectTo(endpoint.url)
+                    .alwaysSeparate()
             conn.rpc?.basicAuth?.let { auth ->
-                rpcClient.setBasicAuth(auth.username, auth.password)
+                rpcClient.basicAuth(auth.username, auth.password)
             }
             conn.rpc?.tls?.let { tls ->
                 tls.ca?.let { ca ->
-                    fileResolver.resolve(ca).inputStream().use { cert -> rpcClient.setTrustedCertificate(cert) }
+                    fileResolver.resolve(ca).inputStream().use { cert -> rpcClient.trustedCertificate(cert) }
                 }
             }
             rpcApi = DirectEthereumApi(

src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/EthereumWs.kt

@@ -45,10 +45,13 @@ class EthereumWs(
 
     fun connect() {
         log.info("Connecting to WebSocket: $uri")
-        val client = WebsocketClient(uri, origin)
+        val clientBuilder = WebsocketClient.newBuilder()
+                .connectTo(uri)
+                .origin(origin)
         basicAuth?.let { auth ->
-            client.setBasicAuth(auth.username, auth.password)
+            clientBuilder.basicAuth(auth.username, auth.password)
         }
+        val client = clientBuilder.build()
         try {
             client.connect()
         } catch (e: Exception) {

src/main/kotlin/io/emeraldpay/dshackle/upstream/grpc/GrpcUpstreams.kt

@@ -74,8 +74,8 @@ class GrpcUpstreams(
         val client = ReactorBlockchainGrpc.newReactorStub(channel.build())
         this.client = client
         this.grpcTransport = ReactorEmeraldClient.newBuilder()
-                .forChannel(client.channel)
+                .connectUsing(client.channel)
-                .setObjectMapper(objectMapper)
+                .objectMapper(objectMapper)
                 .build()
 
         val statusSubscription = AtomicReference<Disposable>()