Skip to content

Commit

Permalink
zeebe dep 8.1.1->8.1.23, pollInt prop configurable, 1-> 10 (#61)
Browse files Browse the repository at this point in the history
  • Loading branch information
Anover000 authored Feb 15, 2024
1 parent 2a09be4 commit 4d09ac3
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 4 deletions.
2 changes: 1 addition & 1 deletion build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ dependencies {
implementation 'org.json:json:20210307'
implementation 'org.apache.cxf:cxf-rt-rs-client:3.2.5'
implementation 'org.apache.cxf:cxf-rt-frontend-jaxrs:3.2.5'
implementation 'io.camunda:zeebe-client-java:8.1.1'
implementation 'io.camunda:zeebe-client-java:8.1.23'
testImplementation 'org.springframework.boot:spring-boot-starter-test:2.2.2.RELEASE'
testImplementation 'org.junit.jupiter:junit-jupiter-api:5.6.0'
testImplementation 'org.junit.jupiter:junit-jupiter-engine:5.6.0'
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,10 +17,13 @@ public class ZeebeClientConfiguration {
@Value("${zeebe.client.max-execution-threads}")
private int zeebeClientMaxThreads;

@Value("${zeebe.client.poll-interval}")
private int zeebeClientPollInterval;

@Bean
public ZeebeClient setup() {
return ZeebeClient.newClientBuilder().gatewayAddress(zeebeBrokerContactpoint).usePlaintext()
.defaultJobPollInterval(Duration.ofMillis(1)).defaultJobWorkerMaxJobsActive(2000)
.defaultJobPollInterval(Duration.ofMillis(zeebeClientPollInterval)).defaultJobWorkerMaxJobsActive(2000)
.numJobWorkerExecutionThreads(zeebeClientMaxThreads).build();
}
}
4 changes: 2 additions & 2 deletions src/main/resources/application.yml
Original file line number Diff line number Diff line change
Expand Up @@ -10,9 +10,9 @@ dfspids: "DFSPID"

zeebe:
client:
max-execution-threads: 1000
max-execution-threads: 50
evenly-allocated-max-jobs: 1000
# max-execution-threads: 100
poll-interval: 10
# number-of-workers: 8
# evenly-allocated-max-jobs: "#{${zeebe.client.max-execution-threads} / ${zeebe.client.number-of-workers}}"
broker:
Expand Down

0 comments on commit 4d09ac3

Please sign in to comment.