Moving the question from meenarc out of Remote Camunda Kafka usage · Issue #25 · berndruecker/flowing-retail · GitHub into this forum:
Was looking through the use cases here where the examples show how to use the embedded camunda to talk to Kafka
We have a use case where a remote Camunda cluster would be used for service orchestration across multiple use cases.
In such cases we would have a flow where the remote service may send/receive messages to the event bus and remote Camunda would need to process these messages…
Also the same or diff workflow can talk to different kafka topics and send /receive diff events
What are the options in such cases when designing the workflow?
- Send task to send messages?
- Receive task-but can we receive messages from diff topics within the same workflow?How do we handle kafka topic offset reset in case of retries etc in such cases?
- Have a customized service task to handle kafka communication , deployed in the remote engine ? This lets us throw in some JSON customization,error handling etc . This approach is sort of what we are leaning towards now.
- Create a custom kafka connector?