diff --git a/kogito-quarkus-examples/kogito-travel-agency/extended/travels/src/main/resources/application.properties b/kogito-quarkus-examples/kogito-travel-agency/extended/travels/src/main/resources/application.properties index 27fd6b1952..5869751c51 100644 --- a/kogito-quarkus-examples/kogito-travel-agency/extended/travels/src/main/resources/application.properties +++ b/kogito-quarkus-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 \ No newline at end of file +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 \ No newline at end of file diff --git a/kogito-quarkus-examples/kogito-travel-agency/extended/travels/src/test/resources/application.properties b/kogito-quarkus-examples/kogito-travel-agency/extended/travels/src/test/resources/application.properties index 86ab76e8b7..6242af5d67 100644 --- a/kogito-quarkus-examples/kogito-travel-agency/extended/travels/src/test/resources/application.properties +++ b/kogito-quarkus-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 \ No newline at end of file +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 \ No newline at end of file diff --git a/kogito-quarkus-examples/kogito-travel-agency/extended/visas/src/main/resources/application.properties b/kogito-quarkus-examples/kogito-travel-agency/extended/visas/src/main/resources/application.properties index ad08d0b5be..a65a220a04 100644 --- a/kogito-quarkus-examples/kogito-travel-agency/extended/visas/src/main/resources/application.properties +++ b/kogito-quarkus-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/kogito-quarkus-examples/process-kafka-multi-quarkus/src/main/resources/application.properties b/kogito-quarkus-examples/process-kafka-multi-quarkus/src/main/resources/application.properties index 4c6187bc53..44c825058b 100644 --- a/kogito-quarkus-examples/process-kafka-multi-quarkus/src/main/resources/application.properties +++ b/kogito-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 \ No newline at end of file +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/kogito-quarkus-examples/process-mongodb-persistence-quarkus/src/main/resources/application.properties b/kogito-quarkus-examples/process-mongodb-persistence-quarkus/src/main/resources/application.properties index e09567d08d..9c7cd32267 100644 --- a/kogito-quarkus-examples/process-mongodb-persistence-quarkus/src/main/resources/application.properties +++ b/kogito-quarkus-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 \ No newline at end of file +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 \ No newline at end of file diff --git a/kogito-quarkus-examples/process-postgresql-persistence-quarkus/src/main/resources/application.properties b/kogito-quarkus-examples/process-postgresql-persistence-quarkus/src/main/resources/application.properties index 365c3484e5..a68288a52e 100644 --- a/kogito-quarkus-examples/process-postgresql-persistence-quarkus/src/main/resources/application.properties +++ b/kogito-quarkus-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 index 0f36eb7eed..58d33b2d1a 100644 --- 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 \ No newline at end of file +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 index f6b90c458e..dad6fd0513 100644 --- 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 \ No newline at end of file +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-usertasks-quarkus-with-console/src/main/resources/application.properties b/kogito-quarkus-examples/process-usertasks-quarkus-with-console/src/main/resources/application.properties index c058567ec9..71dcf17d37 100644 --- a/kogito-quarkus-examples/process-usertasks-quarkus-with-console/src/main/resources/application.properties +++ b/kogito-quarkus-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/kogito-quarkus-examples/process-usertasks-quarkus-with-console/src/test/resources/application.properties b/kogito-quarkus-examples/process-usertasks-quarkus-with-console/src/test/resources/application.properties index 86ab76e8b7..6242af5d67 100644 --- a/kogito-quarkus-examples/process-usertasks-quarkus-with-console/src/test/resources/application.properties +++ b/kogito-quarkus-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 \ No newline at end of file +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 \ No newline at end of file diff --git a/kogito-quarkus-examples/process-usertasks-timer-quarkus-with-console/src/main/resources/application.properties b/kogito-quarkus-examples/process-usertasks-timer-quarkus-with-console/src/main/resources/application.properties index ff7c0e825e..932e513803 100644 --- a/kogito-quarkus-examples/process-usertasks-timer-quarkus-with-console/src/main/resources/application.properties +++ b/kogito-quarkus-examples/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/kogito-quarkus-examples/process-usertasks-timer-quarkus-with-console/src/test/resources/application.properties b/kogito-quarkus-examples/process-usertasks-timer-quarkus-with-console/src/test/resources/application.properties index 9ef27d9280..a26bea6b3c 100644 --- a/kogito-quarkus-examples/process-usertasks-timer-quarkus-with-console/src/test/resources/application.properties +++ b/kogito-quarkus-examples/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 \ No newline at end of file diff --git a/kogito-quarkus-examples/process-usertasks-with-security-oidc-quarkus-with-console/src/main/resources/application.properties b/kogito-quarkus-examples/process-usertasks-with-security-oidc-quarkus-with-console/src/main/resources/application.properties index 476b7c8b47..24259d03c1 100644 --- a/kogito-quarkus-examples/process-usertasks-with-security-oidc-quarkus-with-console/src/main/resources/application.properties +++ b/kogito-quarkus-examples/process-usertasks-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/kogito-quarkus-examples/process-usertasks-with-security-oidc-quarkus-with-console/src/test/resources/application.properties b/kogito-quarkus-examples/process-usertasks-with-security-oidc-quarkus-with-console/src/test/resources/application.properties index 6ba1a27bc4..d7fdc50ccc 100644 --- a/kogito-quarkus-examples/process-usertasks-with-security-oidc-quarkus-with-console/src/test/resources/application.properties +++ b/kogito-quarkus-examples/process-usertasks-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 \ No newline at end of file diff --git a/serverless-workflow-examples/serverless-workflow-callback-quarkus/src/main/resources/application.properties b/serverless-workflow-examples/serverless-workflow-callback-quarkus/src/main/resources/application.properties index bc5e342d20..9fb8268b41 100644 --- a/serverless-workflow-examples/serverless-workflow-callback-quarkus/src/main/resources/application.properties +++ b/serverless-workflow-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/serverless-workflow-examples/serverless-workflow-data-index-quarkus/src/main/resources/application.properties b/serverless-workflow-examples/serverless-workflow-data-index-quarkus/src/main/resources/application.properties index 7042f4dbde..5a7d177d58 100644 --- a/serverless-workflow-examples/serverless-workflow-data-index-quarkus/src/main/resources/application.properties +++ b/serverless-workflow-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/serverless-workflow-examples/serverless-workflow-newsletter-subscription/subscription-flow/src/main/resources/application-knative.properties b/serverless-workflow-examples/serverless-workflow-newsletter-subscription/subscription-flow/src/main/resources/application-knative.properties index e7882dd84d..008cfa2a48 100644 --- a/serverless-workflow-examples/serverless-workflow-newsletter-subscription/subscription-flow/src/main/resources/application-knative.properties +++ b/serverless-workflow-examples/serverless-workflow-newsletter-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/serverless-workflow-examples/serverless-workflow-newsletter-subscription/subscription-flow/src/main/resources/application.properties b/serverless-workflow-examples/serverless-workflow-newsletter-subscription/subscription-flow/src/main/resources/application.properties index 5b4377215c..454e33ca9b 100644 --- a/serverless-workflow-examples/serverless-workflow-newsletter-subscription/subscription-flow/src/main/resources/application.properties +++ b/serverless-workflow-examples/serverless-workflow-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 \ No newline at end of file +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