Stephan Ewen created FLINK-23281:
------------------------------------
Summary: StateFun - Simplify Getting Stared Experience with HTTP
Ingresses and Egresses
Key: FLINK-23281
URL: https://issues.apache.org/jira/browse/FLINK-23281
Project: Flink
Issue Type: New Feature
Components: Stateful Functions
Reporter: Stephan Ewen
To make it easier to get started with StateFun, we want to reduce the
dependencies on other systems and tools that are currently required to get your
first program running.
_(For reference, you currently need a docker-compose setup with at least Flink,
Kafka, ZooKeeper, and then you need to interact with it using Kafka command
line tools (or other clients) to publish messages to the ingress topic.)_
This issue aims to add simple pre-packaged HTTP ingresses/egresses that can be
used for examples and exploration, and can be used with standard tools (like
\{{curl}}). That reduces the barrier to exploration.
_(Citing @ssc here: you have roughlyone lunchbreak of time to get a developer
excited. Many devs just play around for about 45 minutes, and when they don't
see some preliminary success with simple examples, they drop the exploration.)_
An example interaction could be:
{code}
> curl -X POST -i http://<statefun-service>:5555/in/example/greeter/Igal
HTTP/2 200
request-id: 8acb377c-fc5e-4bdb-b2cc-eddb5992b7b5
> curl -X GET
> http://<statefun-service>:5555/out/8acb377c-fc5e-4bdb-b2cc-eddb5992b7b5
Hello for the 1337th time...
{code}
*Note:* The HTTP Ingress/Egress here are different from the HTTP state access
from FLINK-23261.
State requests against the state access API (FLINK-23261) only interacts with
state entries and never invoke functions. In contrast, messages against the
here-proposed Ingress/Egress send messages to functions like any other ingress.
This is the umbrella issue. Dedicated tasks for ingress/egress and request
correlation are in the subtasks.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
