Skip to content

Implement the newOutputMessage (just like java) in the python context #23816

@szindel

Description

@szindel

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.

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions