You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/03/10 16:20:00 UTC
[jira] [Created] (FLINK-21721) Add a generic egress message builder
to the SDK
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)