Pulsar geo-replication 部署失败

我使用 pulsar-helm-char 部署了两套集群,zk 都是独立的,直接设置 components.zookeeper = true

然后我分别在这两个集群执行以下命令:

然后我za在 tcloud 集群创建一个租户,ns, arsenal 集群为能同步

  1. 在 tcloud 集群创建租户(ws),ns(ws/ns1)
  2. 在 arsenal 集群查看,无法查到租户 wk 信息
    截屏2022-10-24 下午9.45.25

我在 tcloud 集群 发送 消息,然后查看 topic 状态,一下是状态信息

{
  "msgRateIn" : 0.2015584874054412,
  "msgThroughputIn" : 589.5585756609155,
  "msgRateOut" : 0.0,
  "msgThroughputOut" : 0.0,
  "bytesInCounter" : 24429514,
  "msgInCounter" : 19294,
  "bytesOutCounter" : 443038,
  "msgOutCounter" : 4808,
  "averageMsgSize" : 731.25,
  "msgChunkPublished" : false,
  "storageSize" : 24429514,
  "backlogSize" : 13772,
  "publishRateLimitedTimes" : 0,
  "offloadedStorageSize" : 0,
  "lastOffloadLedgerId" : 0,
  "lastOffloadSuccessTimeStamp" : 0,
  "lastOffloadFailureTimeStamp" : 0,
  "publishers" : [ {
    "msgRateIn" : 0.2015584874054412,
    "msgThroughputIn" : 589.5585756609155,
    "averageMsgSize" : 731.25,
    "chunkedMessageRate" : 0.0,
    "producerId" : 0
  } ],
  "waitingPublishers" : 0,
  "subscriptions" : {
    "default" : {
      "msgRateOut" : 0.0,
      "msgThroughputOut" : 0.0,
      "bytesOutCounter" : 443038,
      "msgOutCounter" : 4808,
      "msgRateRedeliver" : 0.0,
      "chunkedMessageRate" : 0,
      "msgBacklog" : 7,
      "backlogSize" : 0,
      "msgBacklogNoDelayed" : 7,
      "blockedSubscriptionOnUnackedMsgs" : false,
      "msgDelayed" : 0,
      "unackedMessages" : 0,
      "msgRateExpired" : 3.423707635997718,
      "totalMsgExpired" : 14490,
      "lastExpireTimestamp" : 0,
      "lastConsumedFlowTimestamp" : 0,
      "lastConsumedTimestamp" : 0,
      "lastAckedTimestamp" : 0,
      "lastMarkDeleteAdvancedTimestamp" : 0,
      "consumers" : [ ],
      "isDurable" : true,
      "isReplicated" : false,
      "allowOutOfOrderDelivery" : false,
      "consumersAfterMarkDeletePosition" : { },
      "nonContiguousDeletedMessagesRanges" : 0,
      "nonContiguousDeletedMessagesRangesSerializedSize" : 0,
      "durable" : true,
      "replicated" : false
    }
  },
  "replication" : {
    "arsenal" : {
      "msgRateIn" : 0.0,
      "msgThroughputIn" : 0.0,
      "msgRateOut" : 0.0,
      "msgThroughputOut" : 0.0,
      "msgRateExpired" : 0.1903974485367906,
      "replicationBacklog" : 7,
      "connected" : false,
      "replicationDelayInSeconds" : 0
    }
  },
  "nonContiguousDeletedMessagesRanges" : 0,
  "nonContiguousDeletedMessagesRangesSerializedSize" : 0,
  "compaction" : {
    "lastCompactionRemovedEventCount" : 0,
    "lastCompactionSucceedTimestamp" : 0,
    "lastCompactionFailedTimestamp" : 0,
    "lastCompactionDurationTimeInMills" : 0
  },
  "metadata" : {
    "partitions" : 4
  },
  "partitions" : {
    "persistent://user02/ns1/scores-partition-0" : {
      "msgRateIn" : 0.0,
      "msgThroughputIn" : 0.0,
      "msgRateOut" : 0.0,
      "msgThroughputOut" : 0.0,
      "bytesInCounter" : 5955772,
      "msgInCounter" : 4780,
      "bytesOutCounter" : 81944,
      "msgOutCounter" : 1200,
      "averageMsgSize" : 0.0,
      "msgChunkPublished" : false,
      "storageSize" : 5955772,
      "backlogSize" : 5917,
      "publishRateLimitedTimes" : 0,
      "offloadedStorageSize" : 0,
      "lastOffloadLedgerId" : 0,
      "lastOffloadSuccessTimeStamp" : 0,
      "lastOffloadFailureTimeStamp" : 0,
      "publishers" : [ {
        "accessMode" : "Shared",
        "msgRateIn" : 0.0,
        "msgThroughputIn" : 0.0,
        "averageMsgSize" : 0.0,
        "chunkedMessageRate" : 0.0,
        "producerId" : 3,
        "metadata" : { },
        "address" : "/10.0.48.200:46100",
        "connectedSince" : "2022-10-25T03:35:38.878015Z",
        "producerName" : "tcloud-6-33"
      } ],
      "waitingPublishers" : 0,
      "subscriptions" : {
        "default" : {
          "msgRateOut" : 0.0,
          "msgThroughputOut" : 0.0,
          "bytesOutCounter" : 81944,
          "msgOutCounter" : 1200,
          "msgRateRedeliver" : 0.0,
          "chunkedMessageRate" : 0,
          "msgBacklog" : 1,
          "backlogSize" : 0,
          "msgBacklogNoDelayed" : 1,
          "blockedSubscriptionOnUnackedMsgs" : false,
          "msgDelayed" : 0,
          "unackedMessages" : 0,
          "type" : "Exclusive",
          "msgRateExpired" : 0.10594937681111251,
          "totalMsgExpired" : 3579,
          "lastExpireTimestamp" : 1666668934530,
          "lastConsumedFlowTimestamp" : 1666667940554,
          "lastConsumedTimestamp" : 0,
          "lastAckedTimestamp" : 0,
          "lastMarkDeleteAdvancedTimestamp" : 1666668934532,
          "consumers" : [ ],
          "isDurable" : true,
          "isReplicated" : false,
          "allowOutOfOrderDelivery" : false,
          "consumersAfterMarkDeletePosition" : { },
          "nonContiguousDeletedMessagesRanges" : 0,
          "nonContiguousDeletedMessagesRangesSerializedSize" : 0,
          "durable" : true,
          "replicated" : false
        }
      },
      "replication" : {
        "arsenal" : {
          "msgRateIn" : 0.0,
          "msgThroughputIn" : 0.0,
          "msgRateOut" : 0.0,
          "msgThroughputOut" : 0.0,
          "msgRateExpired" : 0.0010621234571433376,
          "replicationBacklog" : 1,
          "connected" : false,
          "replicationDelayInSeconds" : 0
        }
      },
      "deduplicationStatus" : "Disabled",
      "nonContiguousDeletedMessagesRanges" : 0,
      "nonContiguousDeletedMessagesRangesSerializedSize" : 0,
      "compaction" : {
        "lastCompactionRemovedEventCount" : 0,
        "lastCompactionSucceedTimestamp" : 0,
        "lastCompactionFailedTimestamp" : 0,
        "lastCompactionDurationTimeInMills" : 0
      }
    },
    "persistent://user02/ns1/scores-partition-2" : {
      "msgRateIn" : 0.0,
      "msgThroughputIn" : 0.0,
      "msgRateOut" : 0.0,
      "msgThroughputOut" : 0.0,
      "bytesInCounter" : 6185734,
      "msgInCounter" : 4900,
      "bytesOutCounter" : 98846,
      "msgOutCounter" : 1236,
      "averageMsgSize" : 0.0,
      "msgChunkPublished" : false,
      "storageSize" : 6185734,
      "backlogSize" : 0,
      "publishRateLimitedTimes" : 0,
      "offloadedStorageSize" : 0,
      "lastOffloadLedgerId" : 0,
      "lastOffloadSuccessTimeStamp" : 0,
      "lastOffloadFailureTimeStamp" : 0,
      "publishers" : [ {
        "accessMode" : "Shared",
        "msgRateIn" : 0.0,
        "msgThroughputIn" : 0.0,
        "averageMsgSize" : 0.0,
        "chunkedMessageRate" : 0.0,
        "producerId" : 4,
        "metadata" : { },
        "address" : "/10.0.48.200:46100",
        "connectedSince" : "2022-10-25T03:35:38.878548Z",
        "producerName" : "tcloud-6-32"
      } ],
      "waitingPublishers" : 0,
      "subscriptions" : {
        "default" : {
          "msgRateOut" : 0.0,
          "msgThroughputOut" : 0.0,
          "bytesOutCounter" : 98846,
          "msgOutCounter" : 1236,
          "msgRateRedeliver" : 0.0,
          "chunkedMessageRate" : 0,
          "msgBacklog" : 0,
          "backlogSize" : 0,
          "msgBacklogNoDelayed" : 0,
          "blockedSubscriptionOnUnackedMsgs" : false,
          "msgDelayed" : 0,
          "unackedMessages" : 0,
          "type" : "Exclusive",
          "msgRateExpired" : 0.006666677682373757,
          "totalMsgExpired" : 3664,
          "lastExpireTimestamp" : 1666668634530,
          "lastConsumedFlowTimestamp" : 1666667940555,
          "lastConsumedTimestamp" : 0,
          "lastAckedTimestamp" : 0,
          "lastMarkDeleteAdvancedTimestamp" : 1666668634532,
          "consumers" : [ ],
          "isDurable" : true,
          "isReplicated" : false,
          "allowOutOfOrderDelivery" : false,
          "consumersAfterMarkDeletePosition" : { },
          "nonContiguousDeletedMessagesRanges" : 0,
          "nonContiguousDeletedMessagesRangesSerializedSize" : 0,
          "durable" : true,
          "replicated" : false
        }
      },
      "replication" : {
        "arsenal" : {
          "msgRateIn" : 0.0,
          "msgThroughputIn" : 0.0,
          "msgRateOut" : 0.0,
          "msgThroughputOut" : 0.0,
          "msgRateExpired" : 0.006666683044306901,
          "replicationBacklog" : 0,
          "connected" : false,
          "replicationDelayInSeconds" : 0
        }
      },
      "deduplicationStatus" : "Disabled",
      "nonContiguousDeletedMessagesRanges" : 0,
      "nonContiguousDeletedMessagesRangesSerializedSize" : 0,
      "compaction" : {
        "lastCompactionRemovedEventCount" : 0,
        "lastCompactionSucceedTimestamp" : 0,
        "lastCompactionFailedTimestamp" : 0,
        "lastCompactionDurationTimeInMills" : 0
      }
    },
    "persistent://user02/ns1/scores-partition-1" : {
      "msgRateIn" : 0.0,
      "msgThroughputIn" : 0.0,
      "msgRateOut" : 0.0,
      "msgThroughputOut" : 0.0,
      "bytesInCounter" : 6144903,
      "msgInCounter" : 4758,
      "bytesOutCounter" : 180258,
      "msgOutCounter" : 1171,
      "averageMsgSize" : 0.0,
      "msgChunkPublished" : false,
      "storageSize" : 6144903,
      "backlogSize" : 0,
      "publishRateLimitedTimes" : 0,
      "offloadedStorageSize" : 0,
      "lastOffloadLedgerId" : 0,
      "lastOffloadSuccessTimeStamp" : 0,
      "lastOffloadFailureTimeStamp" : 0,
      "publishers" : [ {
        "accessMode" : "Shared",
        "msgRateIn" : 0.0,
        "msgThroughputIn" : 0.0,
        "averageMsgSize" : 0.0,
        "chunkedMessageRate" : 0.0,
        "producerId" : 2,
        "metadata" : { },
        "address" : "/10.0.48.200:53030",
        "connectedSince" : "2022-10-25T03:35:38.884326Z",
        "producerName" : "tcloud-5-16"
      } ],
      "waitingPublishers" : 0,
      "subscriptions" : {
        "default" : {
          "msgRateOut" : 0.0,
          "msgThroughputOut" : 0.0,
          "bytesOutCounter" : 180258,
          "msgOutCounter" : 1171,
          "msgRateRedeliver" : 0.0,
          "chunkedMessageRate" : 0,
          "msgBacklog" : 0,
          "backlogSize" : 0,
          "msgBacklogNoDelayed" : 0,
          "blockedSubscriptionOnUnackedMsgs" : false,
          "msgDelayed" : 0,
          "unackedMessages" : 0,
          "type" : "Exclusive",
          "msgRateExpired" : 3.225089968542409,
          "totalMsgExpired" : 3598,
          "lastExpireTimestamp" : 1666666025014,
          "lastConsumedFlowTimestamp" : 1666667940554,
          "lastConsumedTimestamp" : 0,
          "lastAckedTimestamp" : 0,
          "lastMarkDeleteAdvancedTimestamp" : 1666667403355,
          "consumers" : [ ],
          "isDurable" : true,
          "isReplicated" : false,
          "allowOutOfOrderDelivery" : false,
          "consumersAfterMarkDeletePosition" : { },
          "nonContiguousDeletedMessagesRanges" : 0,
          "nonContiguousDeletedMessagesRangesSerializedSize" : 0,
          "durable" : true,
          "replicated" : false
        }
      },
      "replication" : {
        "arsenal" : {
          "msgRateIn" : 0.0,
          "msgThroughputIn" : 0.0,
          "msgRateOut" : 0.0,
          "msgThroughputOut" : 0.0,
          "msgRateExpired" : 0.09666702590421279,
          "replicationBacklog" : 0,
          "connected" : false,
          "replicationDelayInSeconds" : 0
        }
      },
      "deduplicationStatus" : "Disabled",
      "nonContiguousDeletedMessagesRanges" : 0,
      "nonContiguousDeletedMessagesRangesSerializedSize" : 0,
      "compaction" : {
        "lastCompactionRemovedEventCount" : 0,
        "lastCompactionSucceedTimestamp" : 0,
        "lastCompactionFailedTimestamp" : 0,
        "lastCompactionDurationTimeInMills" : 0
      }
    },
    "persistent://user02/ns1/scores-partition-3" : {
      "msgRateIn" : 0.2015584874054412,
      "msgThroughputIn" : 589.5585756609155,
      "msgRateOut" : 0.0,
      "msgThroughputOut" : 0.0,
      "bytesInCounter" : 6143105,
      "msgInCounter" : 4856,
      "bytesOutCounter" : 81990,
      "msgOutCounter" : 1201,
      "averageMsgSize" : 2925.0,
      "msgChunkPublished" : false,
      "storageSize" : 6143105,
      "backlogSize" : 7855,
      "publishRateLimitedTimes" : 0,
      "offloadedStorageSize" : 0,
      "lastOffloadLedgerId" : 0,
      "lastOffloadSuccessTimeStamp" : 0,
      "lastOffloadFailureTimeStamp" : 0,
      "publishers" : [ {
        "accessMode" : "Shared",
        "msgRateIn" : 0.2015584874054412,
        "msgThroughputIn" : 589.5585756609155,
        "averageMsgSize" : 2925.0,
        "chunkedMessageRate" : 0.0,
        "producerId" : 1,
        "metadata" : { },
        "address" : "/10.0.12.218:45976",
        "connectedSince" : "2022-10-25T03:35:38.873729Z",
        "producerName" : "tcloud-0-16"
      } ],
      "waitingPublishers" : 0,
      "subscriptions" : {
        "default" : {
          "msgRateOut" : 0.0,
          "msgThroughputOut" : 0.0,
          "bytesOutCounter" : 81990,
          "msgOutCounter" : 1201,
          "msgRateRedeliver" : 0.0,
          "chunkedMessageRate" : 0,
          "msgBacklog" : 6,
          "backlogSize" : 0,
          "msgBacklogNoDelayed" : 6,
          "blockedSubscriptionOnUnackedMsgs" : false,
          "msgDelayed" : 0,
          "unackedMessages" : 0,
          "type" : "Exclusive",
          "msgRateExpired" : 0.08600161296182258,
          "totalMsgExpired" : 3649,
          "lastExpireTimestamp" : 1666668849577,
          "lastConsumedFlowTimestamp" : 1666667940551,
          "lastConsumedTimestamp" : 0,
          "lastAckedTimestamp" : 0,
          "lastMarkDeleteAdvancedTimestamp" : 1666668849578,
          "consumers" : [ ],
          "isDurable" : true,
          "isReplicated" : false,
          "allowOutOfOrderDelivery" : false,
          "consumersAfterMarkDeletePosition" : { },
          "nonContiguousDeletedMessagesRanges" : 0,
          "nonContiguousDeletedMessagesRangesSerializedSize" : 0,
          "durable" : true,
          "replicated" : false
        }
      },
      "replication" : {
        "arsenal" : {
          "msgRateIn" : 0.0,
          "msgThroughputIn" : 0.0,
          "msgRateOut" : 0.0,
          "msgThroughputOut" : 0.0,
          "msgRateExpired" : 0.08600161613112758,
          "replicationBacklog" : 6,
          "connected" : false,
          "replicationDelayInSeconds" : 0
        }
      },
      "deduplicationStatus" : "Disabled",
      "nonContiguousDeletedMessagesRanges" : 0,
      "nonContiguousDeletedMessagesRangesSerializedSize" : 0,
      "compaction" : {
        "lastCompactionRemovedEventCount" : 0,
        "lastCompactionSucceedTimestamp" : 0,
        "lastCompactionFailedTimestamp" : 0,
        "lastCompactionDurationTimeInMills" : 0
      }
    }
  }
}

可以在第一个集群生产,第二个集群消费,看看数据能否同步过去。
看配置没啥问题,