Fixing a bug with proxy not being used while configured

celonis · Jul 5, 2024 · 76d5797 · 76d5797
1 parent 81156dc
commit 76d5797
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/connector/src/main/scala/com/celonis/kafka/connect/ems/config/HttpClientConfig.scala b/connector/src/main/scala/com/celonis/kafka/connect/ems/config/HttpClientConfig.scala
@@ -121,12 +121,14 @@ case class ProxiedHttpClientConfig(
     new Proxy(proxyType.javaProxyType, proxyAddr)
   }
 
-  override def customiseHttpClient(builder: OkHttpClient.Builder): OkHttpClient.Builder =
+  override def customiseHttpClient(builder: OkHttpClient.Builder): OkHttpClient.Builder = {
+    builder.proxy(createProxyServer())
     authentication match {
       case Some(auth) if javaProxyType == JavaProxyType.HTTP  => configureHttpProxyAuth(builder, auth)
       case Some(auth) if javaProxyType == JavaProxyType.SOCKS => configureSocksProxyAuth(auth); builder
       case _                                                  => builder
     }
+  }
 
   private def configureSocksProxyAuth(auth: BasicAuthentication): Unit =
     JavaAuthenticator.setDefault(