We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a63eb01 commit cfd78d8Copy full SHA for cfd78d8
1 file changed
pulsar/__init__.py
@@ -780,6 +780,14 @@ def my_listener(consumer, message):
780
Set the batch collection policy for batch receiving.
781
key_shared_policy: class ConsumerKeySharedPolicy
782
Set the key shared policy for use when the ConsumerType is KeyShared.
783
+ regex_subscription_mode: RegexSubscriptionMode, optional
784
+ Set the regex subscription mode for use when the topic is a regex pattern.
785
+
786
+ Supported modes:
787
788
+ * PersistentOnly: By default only subscribe to persistent topics.
789
+ * NonPersistentOnly: Only subscribe to non-persistent topics.
790
+ * AllTopics: Subscribe to both persistent and non-persistent topics.
791
"""
792
_check_type(str, subscription_name, 'subscription_name')
793
_check_type(ConsumerType, consumer_type, 'consumer_type')
0 commit comments