Hi,
I am trying to run
https://github.com/apache/flink-statefun/tree/master/statefun-examples/statefun-greeter-example
<https://github.com/apache/flink-statefun/tree/master/statefun-examples/statefun-greeter-example>
locally
using
https://github.com/apache/flink-statefun/tree/master/statefun-examples/statefun-flink-harness-example
<https://github.com/apache/flink-statefun/tree/master/statefun-examples/statefun-flink-harness-example>
And have several questions.
1. It seems fairly straightforward to use it with in memory message generators,
but I can’t figure out how to add Kafka ingress/Egress so that I can use it
with Kafk
2. GreetingModule already creates StatefulFunctionUniverse and so does
Harness. Is there a way to short circuit it and have Harness get
StatefulFunctionUniverse directly
3. Is there an example on how to write Flink main for stageful function?
4. Is there an example anywhere on how to run such examples in the IDE with
Kafka?
5 There is a great stateful functions example
https://github.com/ververica/flink-statefun-workshop
<https://github.com/ververica/flink-statefun-workshop>, but its readme does not
really describe implementation and neither does this article, referencing it
https://dev.to/morsapaes/flink-stateful-functions-where-to-start-2j39
<https://dev.to/morsapaes/flink-stateful-functions-where-to-start-2j39>. Is
there anything that describes this implementation?
