Implementing Orchestration based Saga Pattern with flowable and Spring boot stream

Dear all

I’m Implementing Orchestration based Saga Pattern with flowable and Spring boot stream as per the below process diagram involving many microservice projects:

the process is paused on “Message Catching Intermediate Event - Product Reserved Event” seems like flowable engine is not catching the received Kafka Message “productReservedEvent” set as the message reference.

Kindly advice if there’s any settings or programmatically (java) to be done in order to fix the issue (catch the message and procced to the next task).

Best Regards