提交 ed2c8997 编写于 作者: B Boyang Jerry Peng 提交者: Matteo Merli

fix context publish signature (#3669)

上级 043f32f8
......@@ -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
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册