Re: [PR] [fix][broker] Replication stuck when partitions count between two clusters is not the same [pulsar]

2024-07-05 Thread via GitHub
poorbarcode commented on code in PR #22983: URL: https://github.com/apache/pulsar/pull/22983#discussion_r1667078640 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractReplicator.java: ## @@ -184,8 +187,42 @@ public void startProducer() { }

Re: [PR] [fix][broker] Replication stuck when partitions count between two clusters is not the same [pulsar]

2024-07-05 Thread via GitHub
poorbarcode commented on code in PR #22983: URL: https://github.com/apache/pulsar/pull/22983#discussion_r1667074885 ## pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ProducerConfigurationData.java: ## @@ -204,6 +204,8 @@ public class ProducerConfigurationData

Re: [PR] [fix][broker] Replication stuck when partitions count between two clusters is not the same [pulsar]

2024-07-05 Thread via GitHub
nodece commented on code in PR #22983: URL: https://github.com/apache/pulsar/pull/22983#discussion_r1666970494 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractReplicator.java: ## @@ -184,8 +187,42 @@ public void startProducer() { }

Re: [PR] [fix][broker] Replication stuck when partitions count between two clusters is not the same [pulsar]

2024-07-05 Thread via GitHub
Demogorgon314 commented on code in PR #22983: URL: https://github.com/apache/pulsar/pull/22983#discussion_r1666513004 ## pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorTest.java: ## @@ -1034,4 +1040,88 @@ public void testConfigReplicationStartAt()

Re: [PR] [fix][broker] Replication stuck when partitions count between two clusters is not the same [pulsar]

2024-07-05 Thread via GitHub
poorbarcode commented on PR #22983: URL: https://github.com/apache/pulsar/pull/22983#issuecomment-2210358547 /pulsarbot rerun-failure-checks -- 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