[improvement][broker]Add replicate all subscription state switch on the broker side.#23769
[improvement][broker]Add replicate all subscription state switch on the broker side.#23769yyj8 wants to merge 2 commits intoapache:masterfrom
Conversation
…he broker side, Resolve code conflicts.
|
@yyj8 The feature added in this PR would need to be covered with a PIP. There's also #23770 which has been proposed just now. Could you work with together with @nodece so that we could combine both features in the same PIP since they are so closely related. That might also impact the design and implementation. /cc @nodece |
|
This PR introduces an override for the To avoid this conflict and align with PIP #23770, I propose modifying this PR to ignore the If you can set the subscription replication in the namespace or topic level, I belive this should be correct. |
Fixes #xyz
#23768
Main Issue: #xyz
#23768
PIP: #xyz
Motivation
In the current version of Pulsar, when performing cluster data synchronization, in order to continue consuming the consumption message location recorded in the source cluster after switching from the source cluster to the target cluster, it is necessary to configure the parameter
repliceSubscriptionState=trueon the client side to replicate the subscribed consumption location information.There may be some issues with this, such as when my cluster needs to be migrated, if there are dozens of business teams involved in this cluster, then I need to align the migration action with all business teams to ensure that everyone switches and changes at the same pace.
However, this difficulty is very high, as there are complex upstream and downstream dependencies in the data flow between different businesses. At the same time, the business needs to modify the code online in order to replicate the subscription status, which makes our migration efficiency heavily dependent on the business.
For this scenario, we expect to have a global control switch for subscription state replication on the server, which can be enabled to replicate all subscription state information in the cluster without the need for business code modification.
Modifications
Add a switch on the broker side to replicate all subscription states from the source cluster to the target cluster.
Verifying this change
(Please pick either of the following options)
This change is a trivial rework / code cleanup without any test coverage.
(or)
This change is already covered by existing tests, such as (please describe tests).
(or)
This change added tests and can be verified as follows:
(example:)
Does this pull request potentially affect one of the following parts:
If the box was checked, please highlight the changes
Documentation
docdoc-requireddoc-not-neededdoc-completeMatching PR in forked repository
PR in forked repository:
yyj8#11