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.
