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:54 UTC
(incubator-kie-kogito-runtimes) 01/01: [Fix #3813] Allowing configuration of output topic for internal events
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