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> 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> 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> wrote: >> >> Hi, >> I am trying to run >> 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 >> >> 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, 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. >> Is there anything that describes this implementation? >> >> >>
