KafkaMirrorMaker2 (0.28.0) when replicas > 1 may sync new topic fail

[huntkalio]

I use KafkaMirrorMaker2 (strimzi version: 0.28.0) to sync topic in kafka clusters. I found that when then mm2 deployment replicas > 1 , it may not sync correctly when create new topic in source kafka cluster.I catch the exception like this

    java.lang.IllegalArgumentException: Illegal character in path at index 47: http://172.22.17.195:8083/connectors/aa-source->bb-target.MirrorSourceConnector/tasks
        at java.base/java.net.URI.create(URI.java:883)
        at org.eclipse.jetty.client.HttpClient.newRequest(HttpClient.java:453)
        at org.apache.kafka.connect.runtime.rest.RestClient.httpRequest(RestClient.java:107)
        at org.apache.kafka.connect.runtime.distributed.DistributedHerder.lambda$reconfigureConnector$32(DistributedHerder.java:1602)
        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.net.URISyntaxException: Illegal character in path at index 47: http://172.22.17.195:8083/connectors/aa-source->bb-target.MirrorSourceConnector/tasks
        at java.base/java.net.URI$Parser.fail(URI.java:2913)
        at java.base/java.net.URI$Parser.checkChars(URI.java:3084)
        at java.base/java.net.URI$Parser.parseHierarchical(URI.java:3166)
        at java.base/java.net.URI$Parser.parse(URI.java:3114)
        at java.base/java.net.URI.<init>(URI.java:600)
        at java.base/java.net.URI.create(URI.java:881)
        ... 8 more

And I found "->" is from here :
https://github.com/strimzi/strimzi-kafka-operator/blob/0198d2bf3bf4e9c00e11cd2dac15e5e82b1561f7/cluster-operator/src/main/java/io/strimzi/operator/cluster/operator/assembly/KafkaMirrorMaker2AssemblyOperator.java#L383C82-L383C82

I dont't test with the last release strimzi version.

[scholzj]

You should share more information -> full operator log, full Mirror Maker log, the custom resource etc.

[huntkalio]

mm2-log.log
the mm2 log is this.(the KafkaMirrorMaker2 CR's some word replace by me;so it may hava little diff)

[scholzj]

I guess it might be this? https://issues.apache.org/jira/browse/KAFKA-9747

[huntkalio]

@scholzj I will upgrade my mirrormaker2 to 3.1.0 to solve this problem, thanks ! Another querstion, can I use mm2( version: 3.1.0) with kafka cluster(3.0.0) ? Do I need upgrade my kafka cluster version to 3.1.0 ?

[scholzj]

It should be possible to use MM2 from Kafka 3.1 with Kafka cluster based on Kafka 3.0.

[huntkalio]

ok, I got it.