[python-client] Support KeySharedPolicy in consumer configuration #47
Comments
|
The issue had no activity for 30 days, mark with Stale label. |
|
This feature would be very useful for numerous use cases of ours. |
BewareMyPower
pushed a commit
that referenced
this issue
Jun 5, 2023
… the consumer when in KeyShared mode. (#109) ### Motivation The pulsar python client lacks support for defining KeyShared behaviour like out of order message delivery and sticky-hash, auto-hash for consumers in KeyShared mode. This PR adds full support. The user can now provide a KeySharedPolicy when starting a consumer with client.subscribe() #47 The ConsumerConfiguration::KeySharedPolicy and related setter/getter are now exposed to the Python client in this PR. ### Modifications - Added pybind11 enum for KeySharedMode in src/enums.cc. - Added pybind11 class for KeySharedPolicy in src/config.cc. - Modified pybind11 class for ConsumerConfiguration and added function to set KeySharedPolicy and function to read KeySharedPolicy. - Added KeySharedPolicy wrapper to pulsar/__init__.py. This wrapper handles KeySharedPolicy initialization and does some value validation. - Added the key_shared_policy parameter to client.subscribe(), some validation, and adding to the config in pulsar/__init__.py. - Added 4 new tests to test the new KeySharedPolicy functionality to tests/pulsar_test.py
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Support for auto-hash and sticky-hash based policy (apache/pulsar#4077) was added to cpp client (apache/pulsar#7842) java (apache/pulsar#5928) & go (apache/pulsar-client-go#363) It would be great to have these changes ported to python client as well.
Describe the solution you'd like
Expose the ConsumerConfiguration::KeySharedPolicy and related setter/getter to Python client.
The text was updated successfully, but these errors were encountered: