Bertalan Kondrat created KAFKA-18843:
----------------------------------------

             Summary: MirrorMaker2 workerId is not unique, but use the same for 
all the workers
                 Key: KAFKA-18843
                 URL: https://issues.apache.org/jira/browse/KAFKA-18843
             Project: Kafka
          Issue Type: Bug
          Components: mirrormaker
    Affects Versions: 3.9.0, 3.8.0, 3.7.0, 4.0.0
            Reporter: Bertalan Kondrat
            Assignee: Bertalan Kondrat
             Fix For: 4.0.0


MirrorMaker2 is using the `sourceAndTarget.toString()` as a workerId, that 
makes all the worker's IDs the same across the distributed herder.

[https://github.com/apache/kafka/blob/d31cbf59dee6a77c1c673db06900ecc238894ed7/connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMaker.java#L243]

 

This not cause any functional issues based on our experience, but renders the 
workerId in the status topic messages and in the rest responses useless or 
misleading.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to