[GitHub] [pulsar] poorbarcode commented on a diff in pull request #19972: [fix][broker] Ignore and remove the replicator cursor when the remote cluster is absent

2023-04-03 Thread via GitHub
poorbarcode commented on code in PR #19972: URL: https://github.com/apache/pulsar/pull/19972#discussion_r1156789638 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java: ## @@ -1696,14 +1696,32 @@ public void openCursorFailed(ManagedLed

[GitHub] [pulsar] poorbarcode commented on a diff in pull request #19972: [fix][broker] Ignore and remove the replicator cursor when the remote cluster is absent

2023-04-01 Thread via GitHub
poorbarcode commented on code in PR #19972: URL: https://github.com/apache/pulsar/pull/19972#discussion_r1155093515 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java: ## @@ -1696,14 +1696,31 @@ public void openCursorFailed(ManagedLed

[GitHub] [pulsar] poorbarcode commented on a diff in pull request #19972: [fix][broker] Ignore and remove the replicator cursor when the remote cluster is absent

2023-03-31 Thread via GitHub
poorbarcode commented on code in PR #19972: URL: https://github.com/apache/pulsar/pull/19972#discussion_r1154121495 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java: ## @@ -338,7 +338,38 @@ public CompletableFuture initialize() {

[GitHub] [pulsar] poorbarcode commented on a diff in pull request #19972: [fix][broker] Ignore and remove the replicator cursor when the remote cluster is absent

2023-03-30 Thread via GitHub
poorbarcode commented on code in PR #19972: URL: https://github.com/apache/pulsar/pull/19972#discussion_r1154072079 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java: ## @@ -338,7 +338,38 @@ public CompletableFuture initialize() {

[GitHub] [pulsar] poorbarcode commented on a diff in pull request #19972: [fix][broker] Ignore and remove the replicator cursor when the remote cluster is absent

2023-03-30 Thread via GitHub
poorbarcode commented on code in PR #19972: URL: https://github.com/apache/pulsar/pull/19972#discussion_r1154048927 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java: ## @@ -338,7 +338,38 @@ public CompletableFuture initialize() {

[GitHub] [pulsar] poorbarcode commented on a diff in pull request #19972: [fix][broker] Ignore and remove the replicator cursor when the remote cluster is absent

2023-03-30 Thread via GitHub
poorbarcode commented on code in PR #19972: URL: https://github.com/apache/pulsar/pull/19972#discussion_r1153979225 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java: ## @@ -338,7 +338,38 @@ public CompletableFuture initialize() {