[jira] [Created] (FLINK-21721) Add a generic egress message builder to the SDK

[Shang Yuanchun (Jira)]

Igal Shilman created FLINK-21721:
------------------------------------

             Summary: Add a generic egress message builder to the SDK
                 Key: FLINK-21721
                 URL: https://issues.apache.org/jira/browse/FLINK-21721
             Project: Flink
          Issue Type: Task
            Reporter: Igal Shilman


The Java SDK is missing a generic egress message builder (an egress that is not Kinesis or Kafka).

This exists in the Python SDK: [https://github.com/apache/flink-statefun/blob/master/statefun-python-sdk/statefun/messages.py#L178]

And it is used to send messages to custom egresses.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)