gaozhangmin opened a new pull request #13470: URL: https://github.com/apache/pulsar/pull/13470
Fix #13347 Support user defined and pluggable consumer selector by adding a broker configuration `keySharedConsumerSelectorStrategy` which default value is `org.apache.pulsar.broker.service.ConsistentHashingStickyKeyConsumerSelector` ### Modification Currently, client can specify keySharedPolicy like this, but only support pre-defined `autoSplitHashRange` and `stickyHashRange`. https://github.com/apache/pulsar/blob/6c7dcc0cf877cfcb8bcea18cde7662ebacb01d4c/pulsar-broker/src/test/java/org/apache/pulsar/client/api/KeySharedSubscriptionTest.java#L1034-L1041 Now, custom keySharedPolicy `KeySharedPolicyCustome` is supported, and the pre configured `keySharedConsumerSelectorStrategy` will be used. If client doesn't have a keySharedPolicy, `KeySharedMode.CUSTOME` will be used. ### Documentation Check the box below and label this PR (if you have committer privilege). Need to update docs? - [ ] `doc-required` (If you need help on updating docs, create a doc issue) - [ ] `no-need-doc` (Please explain why) - [ ] `doc` (If this PR contains doc changes) -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
