ZeebeClient client = ZeebeClient.newClientBuilder().brokerContactPoint("127.0.0.1:26500").build();

JobWorker workerRegistration = client
  .newWorker()
  .jobType("my-service-task")
  .handler(new JobHandler() {
    public void handle(JobClient client, ActivatedJob job) {
      // here: business logic that is executed with every job
      System.out.println(job);
      // and let the workflow engine know we are done.
      // The API can be used blocking or non-blocking
      client.newCompleteCommand(job.getKey()).send().join();
    }
  )
  .timeout(Duration.ofSeconds(10))
  .open();