Hi. So, I have a bunch of services that communicate via kafka topics and currently they form an event chain (i.e. service A produces to a topic, which is consumed by service B, it produces to another topic which is consumed by service C and so on. It is slightly more complicated in reality, but that is not relevant).
I need to change this to an orchestrated flow, but I couldn’t find a way to do that easily with temporal, because workflow would need to react to kafka messages and I’m not sure how to do that properly.
I saw a suggestion to have workflow wait for signals and have a separate service that would listen to kafka topics and signal workflow based on the trigger. Though with this approach I would have to implement a complex retry process in case the signalling fails and also it splits the workflow logic into two(one in temporal and another in this separate service)
Is there a better solution?