You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Bertalan Kondrat (Jira)" <ji...@apache.org> on 2025/02/21 10:36:00 UTC

[jira] [Created] (KAFKA-18843) MirrorMaker2 workerId is not unique, but use the same for all the workers

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)