diff --git a/pulsar-client-cpp/python/pulsar/functions/context.py b/pulsar-client-cpp/python/pulsar/functions/context.py index 26e86069b90ad3502be8d01887df366b20a61af2..bad6f352663f482c1fe9b7a7bc78e002801bf85f 100644 --- a/pulsar-client-cpp/python/pulsar/functions/context.py +++ b/pulsar-client-cpp/python/pulsar/functions/context.py @@ -124,7 +124,7 @@ class Context(object): pass @abstractmethod - def publish(self, topic_name, message, serde_class_name="serde.IdentitySerDe", properties=None, compression_type=None): + def publish(self, topic_name, message, serde_class_name="serde.IdentitySerDe", properties=None, compression_type=None, callback=None): """Publishes message to topic_name by first serializing the message using serde_class_name serde The message will have properties specified if any""" pass