You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@rocketmq.apache.org by "RockteMQ-AI (via GitHub)" <gi...@apache.org> on 2026/09/01 01:08:50 UTC

Re: [I] 【rocketmq-replicator】双集群单向同步，从集群A未推送到集群B，反而推送回A [rocketmq-connect]

RockteMQ-AI commented on issue #554:
URL: https://github.com/apache/rocketmq-connect/issues/554#issuecomment-5487012916

   **Issue Evaluation**
   
   Category: `bug` | Status: **Confirmed**
   
   The replicator is syncing in the reverse direction — data from cluster A is being pushed back to A instead of to B. This suggests the source/endpoint configuration is being misinterpreted or the replicator is defaulting to the wrong cluster.
   
   **Root Cause:** Likely in the endpoint resolution logic of ReplicatorSourceConnector — the src/dst endpoints may be swapped during initialization.
   **Impact:** Data flows in the wrong direction, potentially causing data duplication or loss.
   **Severity:** High
   
   Note: The issue also mentions that `region` and `cloud` parameters are documented as optional but cause 500 errors when omitted — this is a separate documentation/validation bug.
   
   ---
   *Automated evaluation by RockteMQ-AI*


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org