feat: Update to Spring-Zeebe 8.2 and to connectors-bundle 1.18

pom.xml

@@ -23,8 +23,8 @@
     <zeeqs.version>2.9.0</zeeqs.version>
     <eze.version>1.2.0</eze.version>
     <hazelcast.version>1.4.0</hazelcast.version>
-    <spring-zeebe.version>8.1.17</spring-zeebe.version>
-    <camunda-connector-bundle.version>0.17.0</camunda-connector-bundle.version>
+    <spring-zeebe.version>8.2.0</spring-zeebe.version>
+    <camunda-connector-bundle.version>0.18.0</camunda-connector-bundle.version>
     <camunda-connector-sdk.version>0.8.1</camunda-connector-sdk.version>
 
     <kotlin.version>1.8.20</kotlin.version>

src/main/kotlin/org/camunda/community/zeebe/play/connectors/ConnectorsConfig.kt

@@ -4,7 +4,6 @@ import io.camunda.connector.api.secret.SecretProvider
 import io.camunda.connector.runtime.util.ConnectorHelper
 import io.camunda.connector.runtime.util.outbound.ConnectorJobHandler
 import io.camunda.zeebe.client.ZeebeClient
-import io.camunda.zeebe.spring.client.lifecycle.ZeebeClientLifecycle
 import org.slf4j.LoggerFactory
 import org.springframework.boot.autoconfigure.domain.EntityScan
 import org.springframework.boot.context.properties.EnableConfigurationProperties
@@ -28,13 +27,6 @@ class ConnectorsConfig(
 
     @PostConstruct
     fun startConnectors() {
-        if (zeebeClient is ZeebeClientLifecycle) {
-            // The connectors are managed by the Spring Zeebe client itself.
-            // Currently, it is not possible to disable the connectors. See
-            // https://github.com/camunda-community-hub/spring-zeebe/issues/325.
-            return
-        }
-
         if (connectorProperties.mode == ConnectorProperties.ConnectorsMode.ACTIVE) {
             // start all connectors
             connectorService

src/main/kotlin/org/camunda/community/zeebe/play/zeebe/RemoteZeebeConfig.kt

@@ -3,10 +3,12 @@ package org.camunda.community.zeebe.play.zeebe
 import com.fasterxml.jackson.databind.ObjectMapper
 import com.fasterxml.jackson.module.kotlin.KotlinModule
 import com.fasterxml.jackson.module.kotlin.readValue
-import io.camunda.zeebe.spring.client.EnableZeebeClient
+import io.camunda.zeebe.client.ZeebeClient
+import io.camunda.zeebe.spring.client.properties.ZeebeClientConfigurationProperties
 import org.camunda.community.zeebe.play.rest.ZeebeServiceException
 import org.springframework.beans.factory.annotation.Value
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty
+import org.springframework.boot.context.properties.EnableConfigurationProperties
 import org.springframework.context.annotation.Bean
 import org.springframework.context.annotation.Configuration
 import java.net.URI
@@ -18,7 +20,7 @@ import java.time.Instant
 
 @Configuration
 @ConditionalOnProperty(name = ["zeebe.engine"], havingValue = "remote")
-@EnableZeebeClient
+@EnableConfigurationProperties(ZeebeClientConfigurationProperties::class)
 open class RemoteZeebeConfig {
 
     @Value(value = "\${zeebe.clock.endpoint}")
@@ -29,6 +31,13 @@ open class RemoteZeebeConfig {
         return RemoteZeebeService(zeebeClockEndpoint)
     }
 
+    @Bean
+    fun zeebeClient(config: ZeebeClientConfigurationProperties): ZeebeClient {
+        // The Spring-Zeebe client is disabled (configuration issues with embedded engine).
+        // Create the Zeebe client directly using the configuration from Spring-Zeebe.
+        return ZeebeClient.newClient(config)
+    }
+
     class RemoteZeebeService(val clockEndpoint: String) : ZeebeService {
 
         private val httpClient = HttpClient.newHttpClient()
@@ -57,7 +66,8 @@ open class RemoteZeebeConfig {
 
         override fun increaseTime(duration: Duration): Long {
             val offsetMilli = duration.toMillis()
-            val requestBody = HttpRequest.BodyPublishers.ofString("""{ "offsetMilli": $offsetMilli }""")
+            val requestBody =
+                HttpRequest.BodyPublishers.ofString("""{ "offsetMilli": $offsetMilli }""")
 
             val clockResponse = sendRequest(
                 request = HttpRequest.newBuilder()

src/main/resources/application.yml

@@ -7,10 +7,12 @@ zeebe:
   engine: embedded
 
   client:
-
     broker.gatewayAddress: 127.0.0.1:26500
     security.plaintext: true
 
+    # Disable the Zeebe-Spring client to avoid configuration issues with the embedded engine.
+    enabled: false
+
     worker:
       hazelcast:
         connection: localhost:5701

src/test/kotlin/org/camunda/community/zeebe/play/ApplicationTests.kt

@@ -17,7 +17,7 @@ class ApplicationTests(
 
     @Test
     fun `should start application`() {
-        assertThat(mainView).isNotNull();
+        assertThat(mainView).isNotNull()
     }
 
 }