For that particular example, the simulator [1] is responsible for simulating physical drivers and passengers that interact with their corresponding stateful functions [2]. The interaction between the simulator and the stateful functions is happening via four Kafka topics: * to-driver - messages that are sent from the physical drivers (the simulator [1]) to the stateful functions. The messages always carry a driver-id which acts as a routing key (I think that this is what you mean by correlation id) to a specific driver stateful function (FnDriver) * from-driver - messages that are sent from a stateful function with a specific driver id to the simulator * to-passenger - symmetric to to-driver * from-passenger - symmetric to from-driver. The ingress and egress definition are specified here [3], and you may want to checkout how to router is defined as well [4][5].
In addition the simulator is also feeding the UI directly by duplicating the messages to a web socket (see [6]) I hope this clarifies the examples. Igal. [1] https://github.com/ververica/stateful-functions/tree/master/stateful-functions-examples/stateful-functions-ridesharing-example/stateful-functions-ridesharing-example-simulator/src/main/java/com/ververica/statefun/examples/ridesharing/simulator [2] https://github.com/ververica/stateful-functions/tree/master/stateful-functions-examples/stateful-functions-ridesharing-example/stateful-functions-ridesharing-example-functions [3] https://github.com/ververica/stateful-functions/blob/master/stateful-functions-examples/stateful-functions-ridesharing-example/stateful-functions-ridesharing-example-functions/src/main/java/com/ververica/statefun/examples/ridesharing/KafkaSpecs.java#L43 [4] https://github.com/ververica/stateful-functions/blob/master/stateful-functions-examples/stateful-functions-ridesharing-example/stateful-functions-ridesharing-example-functions/src/main/java/com/ververica/statefun/examples/ridesharing/Module.java#L33 [5] https://github.com/ververica/stateful-functions/blob/master/stateful-functions-examples/stateful-functions-ridesharing-example/stateful-functions-ridesharing-example-functions/src/main/java/com/ververica/statefun/examples/ridesharing/InboundDriverRouter.java#L26 [6] https://github.com/ververica/stateful-functions/blob/master/stateful-functions-examples/stateful-functions-ridesharing-example/stateful-functions-ridesharing-example-simulator/src/main/java/com/ververica/statefun/examples/ridesharing/simulator/simulation/Driver.java#L70 On Thu, Oct 31, 2019 at 4:15 PM Flavio Pompermaier <pomperma...@okkam.it> wrote: > Yes, I'm interested in how to read data from a UI..which egress should I > use? If we use a kafka queue, how to filter data received in the topic? > Should I use a correlation id or use a new topic per user? > > Il Gio 31 Ott 2019, 16:08 Igal Shilman <i...@ververica.com> ha scritto: > >> Hi Flavio, >> >> We haven't included the UI source code just yet, we've only used it for >> demos and talks. >> >> The reason is that (1) we didn't put a lot of effort and time there (2) >> didn't check the time to go through the individual dependencies and >> licences. >> But we will add that very soon. >> >> Would having the UI code there would improve your understanding? or is >> there another reason? >> >> Thanks, >> Igal >> >> On Thu, Oct 31, 2019 at 5:44 AM Flavio Pompermaier <pomperma...@okkam.it> >> wrote: >> >>> Hi Vino, >>> I already checked that code but I can't find the UI part :( >>> >>> On Thu, Oct 31, 2019 at 12:32 PM vino yang <yanghua1...@gmail.com> >>> wrote: >>> >>>> Hi Flavio, >>>> >>>> Please see this link.[1] >>>> >>>> Best, >>>> Vino >>>> >>>> [1]: >>>> https://github.com/ververica/stateful-functions/tree/master/stateful-functions-examples/stateful-functions-ridesharing-example >>>> >>>> Flavio Pompermaier <pomperma...@okkam.it> 于2019年10月31日周四 下午4:53写道： >>>> >>>>> Hi to all, >>>>> yould it be possible to provide also the source code of the UI part of >>>>> the ride sharing example? It would be interesting to me how the UI is >>>>> reading the data from the Kafka egress. >>>>> >>>>> Best, >>>>> Flavio >>>>> >>>> >>>
