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? > > >
