From 12133779ce78a57d67cb4d63c0636530ceff65eb Mon Sep 17 00:00:00 2001
From: Greg Harris <greg.harris@aiven.io>
Date: Wed, 12 Apr 2023 12:36:27 -0700
Subject: [PATCH] MINOR: Fix regression in MM2 task forwarding introduced by
 KAFKA-14783

The DistributedHerder was computing the forwarded URL for publishing task
configs incorrectly leading to 404s in MM2 distributed mode.

Signed-off-by: Greg Harris <greg.harris@aiven.io>
---
 .../kafka/connect/runtime/distributed/DistributedHerder.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
index b5f92386ab053..88f92f53f1793 100644
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
+++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
@@ -2044,7 +2044,7 @@ private void publishConnectorTaskConfigs(String connName, List<Map<String, Strin
                                 "because the URL of the leader's REST interface is empty!"), null);
                         return;
                     }
-                    String reconfigUrl = UriBuilder.fromUri(leaderUrl)
+                    String reconfigUrl = namespacedUrl(leaderUrl)
                             .path("connectors")
                             .path(connName)
                             .path("tasks")