search

camunda / connectors

Camunda Connectors
https://docs.camunda.io/docs/components/integration-framework/connectors/out-of-the-box-connectors/available-connectors-overview/
Apache License 2.0
41 stars 39 forks source link

Avoid blocking in job handlers #3498

Open sbuettner opened 1 month ago

sbuettner commented 1 month ago

Is your feature request related to a problem? Please describe.

The current implementation of job workers in the Connectors runtime blocks the zeebe client thread. This can lead to a scenario where we dont work on new jobs despite having resources available as the handler thread is waiting for a Connector result (and the following zeebe command)

Describe the solution you'd like

We should have a solution based on a single thread pool that is responsible for processing all outbound connector jobs that aligns with the maximum number of active jobs but should allow the zeebe client to activate new jobs if resources are available.

We dont need to implement support for non-blocking result type (like Reactors Mono) as part of this. Every Connector can still block but the overall handling of processing the result and handing it back to the zeebe client should be non-blocking.

Additional context

https://forum.camunda.io/t/parallel-execution-of-camunda-8-outbound-connector-jobs/48741/

sbuettner commented 1 month ago

Things to consider: Use virtual threads for the blocking parts & adhere job limit.