Thanks, I will try your suggestions. One more question. Is StatefulFunctionJob the one that is used for Stateful function execution in the docker case?
> On May 22, 2020, at 12:03 AM, Tzu-Li (Gordon) Tai <tzuli...@apache.org> wrote: > > Hi, > > Sorry, I need to correct my comment on using the Kafka ingress / egress with > the Harness. > > That is actually doable, by adding an extra dependency to > `statefun-flink-distribution` in your Harness program. > That pulls in all the other required dependencies required by the Kafka > ingress / egress, such as the source / sink providers and Flink Kafka > connectors. > > Cheers, > Gordon > > On Fri, May 22, 2020 at 12:04 PM Tzu-Li (Gordon) Tai <tzuli...@apache.org > <mailto:tzuli...@apache.org>> wrote: > Are you getting an exception from running the Harness? > The Harness should already have the required configurations, such as the > parent first classloading config. > > Otherwise, if you would like to add your own configuration, use the > `withConfiguration` method on the `Harness` class. > > On Fri, May 22, 2020 at 7:19 AM Boris Lublinsky > <boris.lublin...@lightbend.com <mailto:boris.lublin...@lightbend.com>> wrote: > Also, where do I put flint-conf.yaml in Idea to add additional required > config parameter: > classloader.parent-first-patterns.additional: > org.apache.flink.statefun;org.apache.kafka;com.google.protobuf > > >> On May 21, 2020, at 12:22 PM, Boris Lublinsky <boris.lublin...@lightbend.com >> <mailto:boris.lublin...@lightbend.com>> wrote: >> >> 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? >> >
