You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kie.apache.org by fj...@apache.org on 2025/02/06 20:11:53 UTC
(incubator-kie-kogito-runtimes) branch Fix_#3813 created (now 8f8a8989fe)
This is an automated email from the ASF dual-hosted git repository.
fjtiradosarti pushed a change to branch Fix_#3813
in repository https://gitbox.apache.org/repos/asf/incubator-kie-kogito-runtimes.git
at 8f8a8989fe [Fix #3813] Allowing configuration of output topic for internal events
This branch includes the following new commits:
new 8f8a8989fe [Fix #3813] Allowing configuration of output topic for internal events
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@kie.apache.org
For additional commands, e-mail: commits-help@kie.apache.org
(incubator-kie-kogito-runtimes) 01/01: [Fix #3813] Allowing configuration of output topic for internal events
Posted by fj...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
fjtiradosarti pushed a commit to branch Fix_#3813
in repository https://gitbox.apache.org/repos/asf/incubator-kie-kogito-runtimes.git
commit 8f8a8989fe07f8268e105d9de5c77ef43faa6329
Author: Francisco Javier Tirado Sarti <ft...@redhat.com>
AuthorDate: Thu Feb 6 21:11:15 2025 +0100
[Fix #3813] Allowing configuration of output topic for internal events
---
.../org/kie/kogito/events/spring/KafkaEventPublisher.java | 15 ++++++++++++---
1 file changed, 12 insertions(+), 3 deletions(-)
diff --git a/springboot/addons/events/kafka/src/main/java/org/kie/kogito/events/spring/KafkaEventPublisher.java b/springboot/addons/events/kafka/src/main/java/org/kie/kogito/events/spring/KafkaEventPublisher.java
index 1e164f255f..4299c226b2 100644
--- a/springboot/addons/events/kafka/src/main/java/org/kie/kogito/events/spring/KafkaEventPublisher.java
+++ b/springboot/addons/events/kafka/src/main/java/org/kie/kogito/events/spring/KafkaEventPublisher.java
@@ -55,6 +55,15 @@ public class KafkaEventPublisher implements EventPublisher {
@Value("${kogito.events.usertasks.enabled:true}")
private boolean userTasksEvents;
+ @Value("${kogito.events.processinstances.topic:PROCESS_INSTANCES_TOPIC_NAME}")
+ private String processInstancesTopic;
+
+ @Value("${kogito.events.processdefinitions.topic:PROCESS_DEFINITIONS_TOPIC_NAME}")
+ private String processDefinitionTopic;
+
+ @Value("${kogito.events.usertasks.topic:USER_TASK_INSTANCES_TOPIC_NAME}")
+ private String userTasksTopic;
+
@Override
public void publish(DataEvent<?> event) {
@@ -64,7 +73,7 @@ public class KafkaEventPublisher implements EventPublisher {
case "ProcessInstanceSLADataEvent":
case "ProcessInstanceStateDataEvent":
case "ProcessInstanceVariableDataEvent":
- publishToTopic(event, PROCESS_INSTANCES_TOPIC_NAME);
+ publishToTopic(event, processInstancesTopic);
break;
case "UserTaskInstanceAssignmentDataEvent":
case "UserTaskInstanceAttachmentDataEvent":
@@ -72,10 +81,10 @@ public class KafkaEventPublisher implements EventPublisher {
case "UserTaskInstanceDeadlineDataEvent":
case "UserTaskInstanceStateDataEvent":
case "UserTaskInstanceVariableDataEvent":
- publishToTopic(event, USER_TASK_INSTANCES_TOPIC_NAME);
+ publishToTopic(event, userTasksTopic);
break;
case "ProcessDefinitionEvent":
- publishToTopic(event, PROCESS_DEFINITIONS_TOPIC_NAME);
+ publishToTopic(event, processDefinitionTopic);
break;
default:
logger.debug("Unknown type of event '{}', ignoring for this publisher", event.getType());
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@kie.apache.org
For additional commands, e-mail: commits-help@kie.apache.org