You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Currently the python Context object only has the publish method as option to publish messages to another topic. However this is quite problematic when using sinks in combination with python pulsar functions. Sinks (often) need a schema for every record.
Java already has the newOutputMessage method, that has record schema as function argument. it would be great if this can be added to the python context class.
The text was updated successfully, but these errors were encountered:
Currently the python Context object only has the publish method as option to publish messages to another topic. However this is quite problematic when using sinks in combination with python pulsar functions. Sinks (often) need a schema for every record.
Java already has the newOutputMessage method, that has record schema as function argument. it would be great if this can be added to the python context class.
The text was updated successfully, but these errors were encountered: