I created a flow with the ui-modeler, created the “start event registry event”, created the eventDefinition and channelDefinition. Each time there is a message in Kafka, I got a notification in the execute() method of my service task. However I am not sure how this service task should look like? Should I implement JavaDelegate? In this case, how can I get the message payload? Only through getVariable() method (which is not very convenient)
Another solution is to use a method annotated @KafkaListener(topics = “flowable-pipeline-test”),
then I got the payload (ConsumerRecord), but I kind of bypass Flowable as it works without defining event and channel definition…
So what’s the best practive to implement such a serviceTask ?
Thanks for your help!