We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent dcfd136 commit 1248825Copy full SHA for 1248825
pulsar/__init__.py
@@ -882,6 +882,11 @@ def my_listener(reader, message):
882
Symmetric encryption class implementation, configuring public key encryption messages for the producer
883
and private key decryption messages for the consumer
884
"""
885
+
886
+ # If a pulsar.MessageId object is passed, access the _pulsar.MessageId object
887
+ if isinstance(start_message_id, MessageId):
888
+ start_message_id = start_message_id._msg_id
889
890
_check_type(str, topic, 'topic')
891
_check_type(_pulsar.MessageId, start_message_id, 'start_message_id')
892
_check_type(_schema.Schema, schema, 'schema')
0 commit comments