diff --git a/spring-boot-starter-camunda/src/main/java/io/camunda/zeebe/spring/client/configuration/ZeebeClientAllAutoConfiguration.java b/spring-boot-starter-camunda/src/main/java/io/camunda/zeebe/spring/client/configuration/ZeebeClientAllAutoConfiguration.java index 7bc978f9..bce88a99 100644 --- a/spring-boot-starter-camunda/src/main/java/io/camunda/zeebe/spring/client/configuration/ZeebeClientAllAutoConfiguration.java +++ b/spring-boot-starter-camunda/src/main/java/io/camunda/zeebe/spring/client/configuration/ZeebeClientAllAutoConfiguration.java @@ -12,6 +12,7 @@ import io.camunda.zeebe.spring.client.metrics.MetricsRecorder; import io.camunda.zeebe.spring.client.properties.PropertyBasedZeebeWorkerValueCustomizer; import io.camunda.zeebe.spring.client.properties.ZeebeClientConfigurationProperties; +import java.util.concurrent.Executors; import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.boot.context.properties.EnableConfigurationProperties; @@ -37,7 +38,9 @@ public ZeebeClientAllAutoConfiguration( @Bean @ConditionalOnMissingBean public ZeebeClientExecutorService zeebeClientExecutorService() { - return ZeebeClientExecutorService.createDefault(); + return new ZeebeClientExecutorService( + Executors.newScheduledThreadPool( + configurationProperties.getNumJobWorkerExecutionThreads())); } @Bean