Anup, This is the expected behavior of the MirrorMaker2 application when a connector attempts to reconfigure it's tasks. It is a limitation of the MirrorMaker2 distributed mode, and has an improvement in-progress that I don't believe has been released yet. See https://cwiki.apache.org/confluence/display/KAFKA/KIP-710%3A+Full+support+for+distributed+mode+in+dedicated+MirrorMaker+2.0+clusters for more details. As a workaround, I believe you can restart the MirrorMaker2 connectors to force a reconfiguration.
I hope this helps, Greg Harris On Tue, Feb 7, 2023, 10:47 PM Shirolkar, Anup <anup.shirol...@netapp.com.invalid> wrote: > Hi, > > I have deployed a 3-node mirror maker cluster version 3.2.1 > I have configured the connect-mirror-maker.properties file and started the > mirror service using connect-mirror-maker.sh > > It runs fine but one of the three workers always gets below exception. > If I restart the connect worker with the error, another worker gets the > same error. > > > [2023-02-08 06:11:03,509] ERROR [Worker clientId=connect-2, > groupId=ruh-mm2] Request to leader to reconfigure connector tasks failed > (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1610) > org.apache.kafka.connect.runtime.rest.errors.ConnectRestException: Error > trying to forward REST request: Invalid URI host: null (authority: null) > at > org.apache.kafka.connect.runtime.rest.RestClient.httpRequest(RestClient.java:147) > at > org.apache.kafka.connect.runtime.distributed.DistributedHerder.lambda$reconfigureConnector$32(DistributedHerder.java:1607) > at > java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) > at > java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) > at > java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) > at > java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) > at java.base/java.lang.Thread.run(Thread.java:829) > Caused by: java.lang.IllegalArgumentException: Invalid URI host: null > (authority: null) > at > org.eclipse.jetty.client.HttpClient.checkHost(HttpClient.java:521) > at > org.eclipse.jetty.client.HttpClient.newHttpRequest(HttpClient.java:506) > at > org.eclipse.jetty.client.HttpClient.newRequest(HttpClient.java:464) > at > org.eclipse.jetty.client.HttpClient.newRequest(HttpClient.java:453) > at > org.apache.kafka.connect.runtime.rest.RestClient.httpRequest(RestClient.java:107) > ... 6 more > > What could be wrong here can you please advise. > > > Thanks, > Anup Shirolkar. > > > >
