[Fix #3813] Fixing decivious springboot application properties

apache · Feb 7, 2025 · aa77761 · aa77761
1 parent 44a5c53
commit aa77761
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 10 deletions.
diff --git a/api/kogito-api/src/main/java/org/kie/kogito/process/ProcessInstances.java b/api/kogito-api/src/main/java/org/kie/kogito/process/ProcessInstances.java
@@ -42,7 +42,9 @@ default long migrateAll(String targetProcessId, String targetProcessVersion) {
     }
 
     default Optional<ProcessInstance<T>> findByBusinessKey(String id, ProcessInstanceReadMode mode) {
-        return stream(mode).filter(pi -> id.equals(pi.businessKey())).findAny();
+    	try (Stream<ProcessInstance<T>> stream = stream(mode)) {
+    		return stream.filter(pi -> id.equals(pi.businessKey())).findAny();
+    	}
     }
 
     Stream<ProcessInstance<T>> stream(ProcessInstanceReadMode mode);

diff --git a/...ion-tests/integration-tests-springboot-kafka-it/src/main/resources/application.properties b/...ion-tests/integration-tests-springboot-kafka-it/src/main/resources/application.properties
@@ -27,13 +27,9 @@ spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.Str
 # read/write on the same topic
 kogito.addon.cloudevents.kafka.kogito_outgoing_stream=pingpong
 kogito.addon.cloudevents.kafka.kogito_incoming_stream=pingpong
+
+kogito.events.processinstances.kafka.topic=kogito-processinstances-events
+kogito.events.processdefinitions.kafka.topic=kogito-processdefinitions-events
+kogito.events.usertasks.kafka.topic=kogito-usertaskinstances-events
+
 # Kogito events
-mp.messaging.outgoing.kogito-processinstances-events.connector=smallrye-kafka
-mp.messaging.outgoing.kogito-processinstances-events.topic=kogito-processinstances-events
-mp.messaging.outgoing.kogito-processinstances-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
-mp.messaging.outgoing.kogito-usertaskinstances-events.connector=smallrye-kafka
-mp.messaging.outgoing.kogito-usertaskinstances-events.topic=kogito-usertaskinstances-events
-mp.messaging.outgoing.kogito-usertaskinstances-events.value.serializer=org.apache.kafka.common.serialization.StringSerializer
-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