[KOGITO-9886] adding workflow definitions events configuration (apach…

…e#1821) * KOGITO-9886 adding workflow definitions events configuration
kiegroup · Dec 13, 2023 · 0c282f9 · 0c282f9
1 parent 443e640
commit 0c282f9
Show file tree

Hide file tree

Showing 18 changed files with 86 additions and 8 deletions.
diff --git a/...-examples/kogito-travel-agency/extended/travels/src/main/resources/application.properties b/...-examples/kogito-travel-agency/extended/travels/src/main/resources/application.properties
@@ -66,4 +66,8 @@ mp.messaging.outgoing.kogito-usertaskinstances-events.value.serializer=org.apach
 #mp.messaging.outgoing.kogito-variables-events.bootstrap.servers=localhost:9092
 mp.messaging.outgoing.kogito-variables-events.connector=smallrye-kafka
 mp.messaging.outgoing.kogito-variables-events.topic=kogito-variables-events
-mp.messaging.outgoing.kogito-variables-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
+mp.messaging.outgoing.kogito-variables-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
+
+mp.messaging.outgoing.kogito-processdefinitions-events.connector=smallrye-kafka
+mp.messaging.outgoing.kogito-processdefinitions-events.topic=kogito-processdefinitions-events
+mp.messaging.outgoing.kogito-processdefinitions-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
diff --git a/...-examples/kogito-travel-agency/extended/travels/src/test/resources/application.properties b/...-examples/kogito-travel-agency/extended/travels/src/test/resources/application.properties
@@ -52,4 +52,8 @@ mp.messaging.outgoing.kogito-usertaskinstances-events.value.serializer=org.apach
 #mp.messaging.outgoing.kogito-variables-events.bootstrap.servers=localhost:9092
 mp.messaging.outgoing.kogito-variables-events.connector=smallrye-kafka
 mp.messaging.outgoing.kogito-variables-events.topic=kogito-variables-events
-mp.messaging.outgoing.kogito-variables-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
+mp.messaging.outgoing.kogito-variables-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
+
+mp.messaging.outgoing.kogito-processdefinitions-events.connector=smallrye-kafka
+mp.messaging.outgoing.kogito-processdefinitions-events.topic=kogito-processdefinitions-events
+mp.messaging.outgoing.kogito-processdefinitions-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
diff --git a/...us-examples/kogito-travel-agency/extended/visas/src/main/resources/application.properties b/...us-examples/kogito-travel-agency/extended/visas/src/main/resources/application.properties
@@ -69,4 +69,9 @@ mp.messaging.outgoing.kogito-variables-events.connector=smallrye-kafka
 mp.messaging.outgoing.kogito-variables-events.topic=kogito-variables-events
 mp.messaging.outgoing.kogito-variables-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
 
+#mp.messaging.outgoing.kogito-processdefinitions-events.bootstrap.servers=localhost:9092
+mp.messaging.outgoing.kogito-processdefinitions-events.connector=smallrye-kafka
+mp.messaging.outgoing.kogito-processdefinitions-events.topic=kogito-processdefinitions-events
+mp.messaging.outgoing.kogito-processdefinitions-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
+
 kogito.monitoring.process.useDefault=false
diff --git a/...to-quarkus-examples/process-kafka-multi-quarkus/src/main/resources/application.properties b/...to-quarkus-examples/process-kafka-multi-quarkus/src/main/resources/application.properties
@@ -58,4 +58,10 @@ mp.messaging.outgoing.kogito-variables-events.connector=smallrye-kafka
 mp.messaging.outgoing.kogito-variables-events.topic=kogito-variables-events
 mp.messaging.outgoing.kogito-variables-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
 mp.messaging.outgoing.kogito-variables-events.auto.offset.reset=earliest
-mp.messaging.outgoing.kogito-variables-events.group.id=kogito-kafka-multi
+mp.messaging.outgoing.kogito-variables-events.group.id=kogito-kafka-multi
+
+mp.messaging.outgoing.kogito-processdefinitions-events.connector=smallrye-kafka
+mp.messaging.outgoing.kogito-processdefinitions-events.topic=kogito-processdefinitions-events
+mp.messaging.outgoing.kogito-processdefinitions-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
+mp.messaging.outgoing.kogito-processdefinitions-events.auto.offset.reset=earliest
+mp.messaging.outgoing.kogito-processdefinitions-events.group.id=kogito-kafka-multi
diff --git a/...us-examples/process-mongodb-persistence-quarkus/src/main/resources/application.properties b/...us-examples/process-mongodb-persistence-quarkus/src/main/resources/application.properties
@@ -37,4 +37,8 @@ mp.messaging.outgoing.kogito-usertaskinstances-events.value.serializer=org.apach
 
 mp.messaging.outgoing.kogito-variables-events.connector=smallrye-kafka
 mp.messaging.outgoing.kogito-variables-events.topic=kogito-variables-events
-mp.messaging.outgoing.kogito-variables-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
+mp.messaging.outgoing.kogito-variables-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
+
+mp.messaging.outgoing.kogito-processdefinitions-events.connector=smallrye-kafka
+mp.messaging.outgoing.kogito-processdefinitions-events.topic=kogito-processdefinitions-events
+mp.messaging.outgoing.kogito-processdefinitions-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
diff --git a/...examples/process-postgresql-persistence-quarkus/src/main/resources/application.properties b/...examples/process-postgresql-persistence-quarkus/src/main/resources/application.properties
@@ -39,3 +39,7 @@ mp.messaging.outgoing.kogito-usertaskinstances-events.value.serializer=org.apach
 mp.messaging.outgoing.kogito-variables-events.connector=smallrye-kafka
 mp.messaging.outgoing.kogito-variables-events.topic=kogito-variables-events
 mp.messaging.outgoing.kogito-variables-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
+
+mp.messaging.outgoing.kogito-processdefinitions-events.connector=smallrye-kafka
+mp.messaging.outgoing.kogito-processdefinitions-events.topic=kogito-processdefinitions-events
+mp.messaging.outgoing.kogito-processdefinitions-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
diff --git a/kogito-quarkus-examples/process-quarkus-example/src/main/resources/application.properties b/kogito-quarkus-examples/process-quarkus-example/src/main/resources/application.properties
@@ -37,4 +37,8 @@ mp.messaging.outgoing.kogito-usertaskinstances-events.value.serializer=org.apach
 
 mp.messaging.outgoing.kogito-variables-events.connector=smallrye-kafka
 mp.messaging.outgoing.kogito-variables-events.topic=kogito-variables-events
-mp.messaging.outgoing.kogito-variables-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
+mp.messaging.outgoing.kogito-variables-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
+
+mp.messaging.outgoing.kogito-processdefinitions-events.connector=smallrye-kafka
+mp.messaging.outgoing.kogito-processdefinitions-events.topic=kogito-processdefinitions-events
+mp.messaging.outgoing.kogito-processdefinitions-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
diff --git a/kogito-quarkus-examples/process-quarkus-example/src/test/resources/application.properties b/kogito-quarkus-examples/process-quarkus-example/src/test/resources/application.properties
@@ -30,4 +30,8 @@ mp.messaging.outgoing.kogito-usertaskinstances-events.value.serializer=org.apach
 
 mp.messaging.outgoing.kogito-variables-events.connector=smallrye-kafka
 mp.messaging.outgoing.kogito-variables-events.topic=kogito-variables-events
-mp.messaging.outgoing.kogito-variables-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
+mp.messaging.outgoing.kogito-variables-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
+
+mp.messaging.outgoing.kogito-processdefinitions-events.connector=smallrye-kafka
+mp.messaging.outgoing.kogito-processdefinitions-events.topic=kogito-processdefinitions-events
+mp.messaging.outgoing.kogito-processdefinitions-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
diff --git a/...examples/process-usertasks-quarkus-with-console/src/main/resources/application.properties b/...examples/process-usertasks-quarkus-with-console/src/main/resources/application.properties
@@ -46,6 +46,11 @@ mp.messaging.outgoing.kogito-variables-events.connector=smallrye-kafka
 mp.messaging.outgoing.kogito-variables-events.topic=kogito-variables-events
 mp.messaging.outgoing.kogito-variables-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
 
+mp.messaging.outgoing.kogito-processdefinitions-events.connector=smallrye-kafka
+mp.messaging.outgoing.kogito-processdefinitions-events.topic=kogito-processdefinitions-events
+mp.messaging.outgoing.kogito-processdefinitions-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
+
+
 
 %postgresql.kogito.persistence.type=jdbc
 %postgresql.quarkus.datasource.db-kind=postgresql

diff --git a/...examples/process-usertasks-quarkus-with-console/src/test/resources/application.properties b/...examples/process-usertasks-quarkus-with-console/src/test/resources/application.properties
@@ -52,4 +52,8 @@ mp.messaging.outgoing.kogito-usertaskinstances-events.value.serializer=org.apach
 #mp.messaging.outgoing.kogito-variables-events.bootstrap.servers=localhost:9092
 mp.messaging.outgoing.kogito-variables-events.connector=smallrye-kafka
 mp.messaging.outgoing.kogito-variables-events.topic=kogito-variables-events
-mp.messaging.outgoing.kogito-variables-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
+mp.messaging.outgoing.kogito-variables-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
+
+mp.messaging.outgoing.kogito-processdefinitions-events.connector=smallrye-kafka
+mp.messaging.outgoing.kogito-processdefinitions-events.topic=kogito-processdefinitions-events
+mp.messaging.outgoing.kogito-processdefinitions-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
diff --git a/...es/process-usertasks-timer-quarkus-with-console/src/main/resources/application.properties b/...es/process-usertasks-timer-quarkus-with-console/src/main/resources/application.properties
@@ -49,6 +49,11 @@ mp.messaging.outgoing.kogito-variables-events.connector=smallrye-kafka
 mp.messaging.outgoing.kogito-variables-events.topic=kogito-variables-events
 mp.messaging.outgoing.kogito-variables-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
 
+mp.messaging.outgoing.kogito-processdefinitions-events.connector=smallrye-kafka
+mp.messaging.outgoing.kogito-processdefinitions-events.topic=kogito-processdefinitions-events
+mp.messaging.outgoing.kogito-processdefinitions-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
+
+
 #Job-service
 kogito.jobs-service.url=http://localhost:8580
 

diff --git a/...es/process-usertasks-timer-quarkus-with-console/src/test/resources/application.properties b/...es/process-usertasks-timer-quarkus-with-console/src/test/resources/application.properties
@@ -54,5 +54,9 @@ mp.messaging.outgoing.kogito-variables-events.connector=smallrye-kafka
 mp.messaging.outgoing.kogito-variables-events.topic=kogito-variables-events
 mp.messaging.outgoing.kogito-variables-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
 
+mp.messaging.outgoing.kogito-processdefinitions-events.connector=smallrye-kafka
+mp.messaging.outgoing.kogito-processdefinitions-events.topic=kogito-processdefinitions-events
+mp.messaging.outgoing.kogito-processdefinitions-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
+
 #Job-service
 kogito.jobs-service.url=http://localhost:8580
diff --git a/...ertasks-with-security-oidc-quarkus-with-console/src/main/resources/application.properties b/...ertasks-with-security-oidc-quarkus-with-console/src/main/resources/application.properties
@@ -53,6 +53,10 @@ mp.messaging.outgoing.kogito-variables-events.connector=smallrye-kafka
 mp.messaging.outgoing.kogito-variables-events.topic=kogito-variables-events
 mp.messaging.outgoing.kogito-variables-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
 
+mp.messaging.outgoing.kogito-processdefinitions-events.connector=smallrye-kafka
+mp.messaging.outgoing.kogito-processdefinitions-events.topic=kogito-processdefinitions-events
+mp.messaging.outgoing.kogito-processdefinitions-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
+
 # security
 quarkus.oidc.auth-server-url=http://localhost:8480/auth/realms/kogito
 

diff --git a/...ertasks-with-security-oidc-quarkus-with-console/src/test/resources/application.properties b/...ertasks-with-security-oidc-quarkus-with-console/src/test/resources/application.properties
@@ -54,3 +54,7 @@ mp.messaging.outgoing.kogito-usertaskinstances-events.value.serializer=org.apach
 mp.messaging.outgoing.kogito-variables-events.connector=smallrye-kafka
 mp.messaging.outgoing.kogito-variables-events.topic=kogito-variables-events
 mp.messaging.outgoing.kogito-variables-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
+
+mp.messaging.outgoing.kogito-processdefinitions-events.connector=smallrye-kafka
+mp.messaging.outgoing.kogito-processdefinitions-events.topic=kogito-processdefinitions-events
+mp.messaging.outgoing.kogito-processdefinitions-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
diff --git a/...w-examples/serverless-workflow-callback-quarkus/src/main/resources/application.properties b/...w-examples/serverless-workflow-callback-quarkus/src/main/resources/application.properties
@@ -53,6 +53,11 @@ mp.messaging.outgoing.kogito-variables-events.topic=kogito-variables-events
 mp.messaging.outgoing.kogito-variables-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
 
 
+mp.messaging.outgoing.kogito-processdefinitions-events.connector=smallrye-kafka
+mp.messaging.outgoing.kogito-processdefinitions-events.topic=kogito-processdefinitions-events
+mp.messaging.outgoing.kogito-processdefinitions-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
+
+
 kogito.persistence.type=jdbc
 quarkus.datasource.db-kind=postgresql
 kogito.persistence.proto.marshaller=false

diff --git a/...examples/serverless-workflow-data-index-quarkus/src/main/resources/application.properties b/...examples/serverless-workflow-data-index-quarkus/src/main/resources/application.properties
@@ -90,3 +90,6 @@ quarkus.native.native-image-xmx=8g
 %http-events.mp.messaging.outgoing.kogito-variables-events.url=http://data-index:8180/variables
 %http-events.mp.messaging.outgoing.kogito-variables-events.method=POST
 
+%http-events.mp.messaging.outgoing.kogito-processdefinitions-events.connector=quarkus-http
+%http-events.mp.messaging.outgoing.kogito-processdefinitions-events.topic=kogito-processdefinitions-events
+%http-events.mp.messaging.outgoing.kogito-processdefinitions-events.url=http://data-index:8180/processes
diff --git a/...wsletter-subscription/subscription-flow/src/main/resources/application-knative.properties b/...wsletter-subscription/subscription-flow/src/main/resources/application-knative.properties
@@ -57,6 +57,10 @@ mp.messaging.outgoing.kogito-variables-events.connector=quarkus-http
 mp.messaging.outgoing.kogito-variables-events.url=${K_SINK:http://localhost:8180/variables}
 mp.messaging.outgoing.kogito-variables-events.method=POST
 
+mp.messaging.outgoing.kogito-processdefinitions-events.connector=quarkus-http
+mp.messaging.outgoing.kogito-processdefinitions-events.url={K_SINK:http://localhost:8180/definitions}
+mp.messaging.outgoing.kogito-processdefinitions-events.method=POST
+
 ## Knative integration:
 
 # Use the Kogito service discovery mechanism to get the subscription-service url and set an env var with name SUBSCRIPTION_SERVICE_URL

diff --git a/...kflow-newsletter-subscription/subscription-flow/src/main/resources/application.properties b/...kflow-newsletter-subscription/subscription-flow/src/main/resources/application.properties
@@ -63,4 +63,9 @@ mp.messaging.outgoing.kogito-usertaskinstances-events.method=POST
 kogito.events.variables.enabled=false
 mp.messaging.outgoing.kogito-variables-events.connector=quarkus-http
 mp.messaging.outgoing.kogito-variables-events.url=http://localhost:8180/variables
-mp.messaging.outgoing.kogito-variables-events.method=POST
+mp.messaging.outgoing.kogito-variables-events.method=POST
+
+# process definitions events configuration.
+mp.messaging.outgoing.kogito-processdefinitions-events.connector=quarkus-http
+mp.messaging.outgoing.kogito-processdefinitions-events.url=http://localhost:8180/definitions
+mp.messaging.outgoing.kogito-processdefinitions-events.method=POST