debezium · SaidiBTW · Apr 3, 2026
diff --git a/auditlog/.gitignore b/auditlog/.gitignore
@@ -0,0 +1,3 @@
+target
+.quarkus
+connector-config
diff --git a/auditlog/README.md b/auditlog/README.md
@@ -5,37 +5,37 @@ It accompanies the blog post [Building Audit Logs with Change Data Capture and S
 
 There are two applications (based on [Quarkus](https://quarkus.io/)):
 
-* _vegetables-service_: a simple REST service for inserting and updating vegetable data into a Postgres database;
-as part of its processing, it will not only update its actual "business table" `vegetable`,
-but also insert some auditing metadata into a dedicated metadata table `transaction_context_data`:
-the user (as obtained from the passed JWT token), the client's date (as passed via the HTTP 1.1 `Date` header)
-and a use case identifier (as specified in an annotation on the REST API methods).
-* _log-enricher_: a Kafka Streams application,
-which joins the CDC topic holding the `vegetable` change events (`dbserver1.inventory.vegetable`) with the corresponding metadata in the `dbserver1.inventory.transaction_context_data` topic sourced from the `transaction_context_data` table;
-this table is keyed by transaction id, allowing for joining the vegetable `KStream` with the metadata `KTable`.
-The enriched vegetable change events are written to the `dbserver1.inventory.vegetable.enriched` topic.
+- _vegetables-service_: a simple REST service for inserting and updating vegetable data into a Postgres database;
+  as part of its processing, it will not only update its actual "business table" `vegetable`,
+  but also insert some auditing metadata into a dedicated metadata table `transaction_context_data`:
+  the user (as obtained from the passed JWT token), the client's date (as passed via the HTTP 1.1 `Date` header)
+  and a use case identifier (as specified in an annotation on the REST API methods).
+- _log-enricher_: a Kafka Streams application,
+  which joins the CDC topic holding the `vegetable` change events (`dbserver1.inventory.vegetable`) with the corresponding metadata in the `dbserver1.inventory.transaction_context_data` topic sourced from the `transaction_context_data` table;
+  this table is keyed by transaction id, allowing for joining the vegetable `KStream` with the metadata `KTable`.
+  The enriched vegetable change events are written to the `dbserver1.inventory.vegetable.enriched` topic.
 
 ## Building the Demo
 
 ```console
-$ mvn clean package
+mvn clean package
 ```
 
 ```console
-$ export DEBEZIUM_VERSION=1.8
-$ docker-compose up --build
+export DEBEZIUM_VERSION=3.4
+docker-compose up --build
 ```
 
 ## Deploy the Debezium Postgres Connector
 
 ```console
-$ http PUT http://localhost:8083/connectors/inventory-connector/config < register-postgres.json
+http PUT http://localhost:8083/connectors/inventory-connector/config < register-postgres.json
 ```
 
 ## Modifying Some Data and Observing the Audit Log
 
 ```console
-$ http POST http://localhost:8080/vegetables 'Authorization:Bearer eyJraWQiOiJqd3Qua2V5IiwidHlwIjoiSldUIiwiYWxnIjoiUlMyNTYifQ.eyJzdWIiOiJmYXJtZXJib2IiLCJ1cG4iOiJmYXJtZXJib2IiLCJhdXRoX3RpbWUiOjE1NjY0NTgxMTMsImlzcyI6ImZhcm1zaG9wIiwiZ3JvdXBzIjpbImZhcm1lcnMiLCJjdXN0b21lcnMiXSwiZXhwIjo0MTAyNDQ0Nzk5LCJpYXQiOjE1NjY0NTgxMTMsImp0aSI6IjQyIn0.CscbJN8amqKryYvnVO1184J8F67HN2iTEjVN2VOPodcnoeOd7_iQVKUjC3h-ye5apkJjvAsQKrjzlrGCHRfl-n6jC9F7IkOtjoWnJ4wQ9BBo1SAtPw_Czt1I_Ujm-Kb1p5-BWACCBCVVFgYZTWP_laz5JZS7dIvs6VqoNnw7A4VpA6iPfTVfYlNY3u86-k1FvEg_hW-N9Y9RuihMsPuTdpHK5xdjCrJiD0VJ7-0eRQ8RXpycHuHN4xfmV8MqXBYjYSYDOhbnYbdQVbf0YJoFFqfb75my5olN-97ITsi2MS62W_y-RNT0qZrbytqINA3fF3VQsSY6VcaqRAeygrKm_Q' 'Date:Thu, 22 Aug 2019 08:12:31 GMT' name=Tomatoe description=Yummy!
+http POST http://localhost:8080/vegetables 'Authorization:Bearer eyJraWQiOiJqd3Qua2V5IiwidHlwIjoiSldUIiwiYWxnIjoiUlMyNTYifQ.eyJzdWIiOiJmYXJtZXJib2IiLCJ1cG4iOiJmYXJtZXJib2IiLCJhdXRoX3RpbWUiOjE1NjY0NTgxMTMsImlzcyI6ImZhcm1zaG9wIiwiZ3JvdXBzIjpbImZhcm1lcnMiLCJjdXN0b21lcnMiXSwiZXhwIjo0MTAyNDQ0Nzk5LCJpYXQiOjE1NjY0NTgxMTMsImp0aSI6IjQyIn0.CscbJN8amqKryYvnVO1184J8F67HN2iTEjVN2VOPodcnoeOd7_iQVKUjC3h-ye5apkJjvAsQKrjzlrGCHRfl-n6jC9F7IkOtjoWnJ4wQ9BBo1SAtPw_Czt1I_Ujm-Kb1p5-BWACCBCVVFgYZTWP_laz5JZS7dIvs6VqoNnw7A4VpA6iPfTVfYlNY3u86-k1FvEg_hW-N9Y9RuihMsPuTdpHK5xdjCrJiD0VJ7-0eRQ8RXpycHuHN4xfmV8MqXBYjYSYDOhbnYbdQVbf0YJoFFqfb75my5olN-97ITsi2MS62W_y-RNT0qZrbytqINA3fF3VQsSY6VcaqRAeygrKm_Q' 'Date:Thu, 22 Aug 2019 08:12:31 GMT' name=Tomatoe description=Yummy!
 ```
 
 This uses a pre-generated JWT token (with expiration date set to 2099-12-31 and user set to "farmerbob").
@@ -44,33 +44,33 @@ To regenerate the token with different data, use the [Jwtenizr](https://github.c
 You can also update an existing vegetable record (this token is for "farmermargaret"):
 
 ```console
-$ http PUT http://localhost:8080/vegetables/10 'Authorization:Bearer eyJraWQiOiJqd3Qua2V5IiwidHlwIjoiSldUIiwiYWxnIjoiUlMyNTYifQ.eyJzdWIiOiJmYXJtZXJtYXJnYXJldCIsInVwbiI6ImZhcm1lcm1hcmdhcmV0IiwiYXV0aF90aW1lIjoxNTY5ODM1Mzk5LCJpc3MiOiJmYXJtc2hvcCIsImdyb3VwcyI6WyJmYXJtZXJzIiwiY3VzdG9tZXJzIl0sImV4cCI6NDEwMjQ0NDc5OSwiaWF0IjoxNTY5ODM1Mzk5LCJqdGkiOiI0MiJ9.DTEUA3p-xyK5nveoJIVhjfKNFdVszYIb55Qj4Xrm70DDbAXuOU2FMkffuUAUm2s7ACkp2KEmg6brRwSjvA-zhW61kDR9ZgEb9NWeDjr6Eue08xcSODKt7SGV-M7h3yhuDIhU7uaZrxRUAQTWqm1vxd2rmN_QH0frhKMUNFFsLIOGLG0zHcLosRcwZ4tAKXSSB9VE0fth6srIQCUebDkF7ucA_WSYjPRvahCBd8JvnV4VUGQxZW8zcRhTEwcaLq20ODO-dr85xgWI2Yr_1A7PDuDL4oUjCb90YyhtzaIzs2vQMjcxJ6TWmTcqJpgCfkjE-TeVwjaafcNJu0fBmcP8jA' 'Date:Thu, 22 Aug 2019 08:12:31 GMT' name=Tomatoe description=Tasty!
+http PUT http://localhost:8080/vegetables/10 'Authorization:Bearer eyJraWQiOiJqd3Qua2V5IiwidHlwIjoiSldUIiwiYWxnIjoiUlMyNTYifQ.eyJzdWIiOiJmYXJtZXJtYXJnYXJldCIsInVwbiI6ImZhcm1lcm1hcmdhcmV0IiwiYXV0aF90aW1lIjoxNTY5ODM1Mzk5LCJpc3MiOiJmYXJtc2hvcCIsImdyb3VwcyI6WyJmYXJtZXJzIiwiY3VzdG9tZXJzIl0sImV4cCI6NDEwMjQ0NDc5OSwiaWF0IjoxNTY5ODM1Mzk5LCJqdGkiOiI0MiJ9.DTEUA3p-xyK5nveoJIVhjfKNFdVszYIb55Qj4Xrm70DDbAXuOU2FMkffuUAUm2s7ACkp2KEmg6brRwSjvA-zhW61kDR9ZgEb9NWeDjr6Eue08xcSODKt7SGV-M7h3yhuDIhU7uaZrxRUAQTWqm1vxd2rmN_QH0frhKMUNFFsLIOGLG0zHcLosRcwZ4tAKXSSB9VE0fth6srIQCUebDkF7ucA_WSYjPRvahCBd8JvnV4VUGQxZW8zcRhTEwcaLq20ODO-dr85xgWI2Yr_1A7PDuDL4oUjCb90YyhtzaIzs2vQMjcxJ6TWmTcqJpgCfkjE-TeVwjaafcNJu0fBmcP8jA' 'Date:Thu, 22 Aug 2019 08:12:31 GMT' name=Tomatoe description=Tasty!
 ```
 
 Or delete a record (again using the "farmerbob" token):
 
 ```console
-$ http DELETE http://localhost:8080/vegetables/10 'Authorization:Bearer eyJraWQiOiJqd3Qua2V5IiwidHlwIjoiSldUIiwiYWxnIjoiUlMyNTYifQ.eyJzdWIiOiJmYXJtZXJib2IiLCJ1cG4iOiJmYXJtZXJib2IiLCJhdXRoX3RpbWUiOjE1NjY0NTgxMTMsImlzcyI6ImZhcm1zaG9wIiwiZ3JvdXBzIjpbImZhcm1lcnMiLCJjdXN0b21lcnMiXSwiZXhwIjo0MTAyNDQ0Nzk5LCJpYXQiOjE1NjY0NTgxMTMsImp0aSI6IjQyIn0.CscbJN8amqKryYvnVO1184J8F67HN2iTEjVN2VOPodcnoeOd7_iQVKUjC3h-ye5apkJjvAsQKrjzlrGCHRfl-n6jC9F7IkOtjoWnJ4wQ9BBo1SAtPw_Czt1I_Ujm-Kb1p5-BWACCBCVVFgYZTWP_laz5JZS7dIvs6VqoNnw7A4VpA6iPfTVfYlNY3u86-k1FvEg_hW-N9Y9RuihMsPuTdpHK5xdjCrJiD0VJ7-0eRQ8RXpycHuHN4xfmV8MqXBYjYSYDOhbnYbdQVbf0YJoFFqfb75my5olN-97ITsi2MS62W_y-RNT0qZrbytqINA3fF3VQsSY6VcaqRAeygrKm_Q' 'Date:Thu, 22 Aug 2019 08:12:31 GMT'
+http DELETE http://localhost:8080/vegetables/10 'Authorization:Bearer eyJraWQiOiJqd3Qua2V5IiwidHlwIjoiSldUIiwiYWxnIjoiUlMyNTYifQ.eyJzdWIiOiJmYXJtZXJib2IiLCJ1cG4iOiJmYXJtZXJib2IiLCJhdXRoX3RpbWUiOjE1NjY0NTgxMTMsImlzcyI6ImZhcm1zaG9wIiwiZ3JvdXBzIjpbImZhcm1lcnMiLCJjdXN0b21lcnMiXSwiZXhwIjo0MTAyNDQ0Nzk5LCJpYXQiOjE1NjY0NTgxMTMsImp0aSI6IjQyIn0.CscbJN8amqKryYvnVO1184J8F67HN2iTEjVN2VOPodcnoeOd7_iQVKUjC3h-ye5apkJjvAsQKrjzlrGCHRfl-n6jC9F7IkOtjoWnJ4wQ9BBo1SAtPw_Czt1I_Ujm-Kb1p5-BWACCBCVVFgYZTWP_laz5JZS7dIvs6VqoNnw7A4VpA6iPfTVfYlNY3u86-k1FvEg_hW-N9Y9RuihMsPuTdpHK5xdjCrJiD0VJ7-0eRQ8RXpycHuHN4xfmV8MqXBYjYSYDOhbnYbdQVbf0YJoFFqfb75my5olN-97ITsi2MS62W_y-RNT0qZrbytqINA3fF3VQsSY6VcaqRAeygrKm_Q' 'Date:Thu, 22 Aug 2019 08:12:31 GMT'
 ```
 
 Doing so, observe the contents of the `dbserver1.inventory.vegetable`, `dbserver1.inventory.transaction_context_data` and `dbserver1.inventory.vegetable.enriched` topics:
 
 ```console
 $ docker run -it --rm \
     --network auditlog_default \
-    quay.io/debezium/tooling:1.2 \
+    quay.io/debezium/tooling:2.0 \
     /bin/bash -c "kafkacat -b kafka:9092 \
     -C -o beginning -q -u -t dbserver1.inventory.vegetable | jq ."
 
 $ docker run -it --rm \
     --network auditlog_default \
-    quay.io/debezium/tooling:1.2 \
+    quay.io/debezium/tooling:2.0 \
     /bin/bash -c "kafkacat -b kafka:9092 \
     -C -o beginning -q -u -t dbserver1.inventory.transaction_context_data | jq ."
 
 $ docker run -it --rm \
     --network auditlog_default \
-    quay.io/debezium/tooling:1.2 \
+    quay.io/debezium/tooling:2.0 \
     /bin/bash -c "kafkacat -b kafka:9092 \
     -C -o beginning -q -u -t dbserver1.inventory.vegetable.enriched | jq ."
 ```
@@ -105,7 +105,7 @@ create a task for administrator to provide the missing data.
 ```console
 $ docker run --tty --rm -i \
         --network auditlog_default \
-        quay.io/debezium/tooling:1.2 \
+        quay.io/debezium/tooling:2.0 \
         bash -c 'pgcli postgresql://postgresuser:postgrespw@vegetables-db:5432/vegetablesdb'
 ```
 
@@ -147,7 +147,7 @@ This would then fix the missing event in the transaction context data topic and
 ## Stopping All Services
 
 ```console
-$ docker-compose down
+docker-compose down
 ```
 
 ## Running the Quarkus Applications Locally
@@ -156,7 +156,7 @@ Set `ADVERTISED_HOST_NAME` of the `kafka` service in _docker-compose.yaml_ to th
 Start all services except the `vegetables-service` and the `log-enricher`:
 
 ```console
-$ docker-compose up --scale vegetables-service=0 --scale log-enricher=0
+docker-compose up --scale vegetables-service=0 --scale log-enricher=0
 ```
 
 Then start the three services via the Quarkus dev mode:

diff --git a/auditlog/admin-service/.dockerignore b/auditlog/admin-service/.dockerignore
@@ -1,4 +1,5 @@
 *
 !target/*-runner
 !target/*-runner.jar
-!target/lib/*
+!target/lib/*
+!target/quarkus-app/*
diff --git a/auditlog/admin-service/pom.xml b/auditlog/admin-service/pom.xml
@@ -1,39 +1,65 @@
-<?xml version="1.0"?>
-<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" xmlns="http://maven.apache.org/POM/4.0.0"
-    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
   <modelVersion>4.0.0</modelVersion>
   <groupId>io.debezium.demos.auditing</groupId>
   <artifactId>auditing-admin-service</artifactId>
   <version>1.0-SNAPSHOT</version>
   <properties>
-    <maven.compiler.source>1.8</maven.compiler.source>
-    <maven.compiler.target>1.8</maven.compiler.target>
-    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
-    <quarkus.version>1.4.2.Final</quarkus.version>
-    <surefire-plugin.version>2.22.0</surefire-plugin.version>
+    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    <maven.compiler.source>21</maven.compiler.source>
+    <maven.compiler.target>21</maven.compiler.target>
+    <quarkus.version>3.15.1</quarkus.version>
+    <surefire-plugin.version>3.2.5</surefire-plugin.version>
+    <kogito.bom.group-id>org.kie.kogito</kogito.bom.group-id>
+    <kogito.bom.artifact-id>kogito-quarkus-bom</kogito.bom.artifact-id>
+    <kogito.bom.version>10.1.0</kogito.bom.version>
   </properties>
+
   <dependencyManagement>
     <dependencies>
       <dependency>
-        <groupId>io.quarkus</groupId>
-        <artifactId>quarkus-universe-bom</artifactId>
+        <groupId>io.quarkus.platform</groupId>
+        <artifactId>quarkus-bom</artifactId>
         <version>${quarkus.version}</version>
         <type>pom</type>
         <scope>import</scope>
       </dependency>
+    <dependency>
+        <groupId>${kogito.bom.group-id}</groupId>
+        <artifactId>${kogito.bom.artifact-id}</artifactId>
+        <version>${kogito.bom.version}</version>
+        <type>pom</type>
+        <scope>import</scope>
+      </dependency>
     </dependencies>
   </dependencyManagement>
+
   <dependencies>
+      <dependency>
+        <groupId>org.kie.kogito</groupId>
+        <artifactId>kogito-api</artifactId>
+      </dependency>
+    <dependency>
+      <groupId>io.quarkus</groupId>
+      <artifactId>quarkus-messaging-kafka</artifactId>
+    </dependency>
     <dependency>
-      <groupId>org.kie.kogito</groupId>
-      <artifactId>kogito-quarkus</artifactId>
+      <groupId>io.quarkus</groupId>
+      <artifactId>quarkus-rest</artifactId>
     </dependency>
     <dependency>
       <groupId>io.quarkus</groupId>
-      <artifactId>quarkus-smallrye-reactive-messaging-kafka</artifactId>
+      <artifactId>quarkus-junit5</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>io.rest-assured</groupId>
+      <artifactId>rest-assured</artifactId>
+      <scope>test</scope>
     </dependency>
   </dependencies>
+
   <build>
     <plugins>
       <plugin>
@@ -52,13 +78,15 @@
         <artifactId>maven-surefire-plugin</artifactId>
         <version>${surefire-plugin.version}</version>
         <configuration>
-          <systemProperties>
+          <systemPropertyVariables>
             <java.util.logging.manager>org.jboss.logmanager.LogManager</java.util.logging.manager>
-          </systemProperties>
+            <maven.home>${maven.home}</maven.home>
+          </systemPropertyVariables>
         </configuration>
       </plugin>
     </plugins>
   </build>
+
   <profiles>
     <profile>
       <id>native</id>
@@ -69,21 +97,6 @@
       </activation>
       <build>
         <plugins>
-          <plugin>
-            <groupId>io.quarkus</groupId>
-            <artifactId>quarkus-maven-plugin</artifactId>
-            <version>${quarkus.version}</version>
-            <executions>
-              <execution>
-                <goals>
-                  <goal>native-image</goal>
-                </goals>
-                <configuration>
-                  <enableHttpUrlHandler>true</enableHttpUrlHandler>
-                </configuration>
-              </execution>
-            </executions>
-          </plugin>
           <plugin>
             <artifactId>maven-failsafe-plugin</artifactId>
             <version>${surefire-plugin.version}</version>
@@ -94,9 +107,11 @@
                   <goal>verify</goal>
                 </goals>
                 <configuration>
-                  <systemProperties>
+                  <systemPropertyVariables>
                     <native.image.path>${project.build.directory}/${project.build.finalName}-runner</native.image.path>
-                  </systemProperties>
+                    <java.util.logging.manager>org.jboss.logmanager.LogManager</java.util.logging.manager>
+                    <maven.home>${maven.home}</maven.home>
+                  </systemPropertyVariables>
                 </configuration>
               </execution>
             </executions>

diff --git a/auditlog/admin-service/src/main/docker/Dockerfile.jvm b/auditlog/admin-service/src/main/docker/Dockerfile.jvm
@@ -14,10 +14,20 @@
 # docker run -i --rm -p 8080:8080 quarkus/admin-service-jvm
 #
 ###
-# FROM fabric8/java-alpine-openjdk8-jre
-FROM fabric8/java-centos-openjdk8-jdk
-ENV JAVA_OPTIONS="-Dquarkus.http.host=0.0.0.0 -Djava.util.logging.manager=org.jboss.logmanager.LogManager"
-ENV AB_ENABLED=jmx_exporter
-COPY target/lib/* /deployments/lib/
-COPY target/*-runner.jar /deployments/app.jar
-ENTRYPOINT [ "/deployments/run-java.sh" ]
+FROM registry.access.redhat.com/ubi8/openjdk-21:1.23
+
+ENV LANGUAGE='en_US:en'
+
+
+# We make four distinct layers so if there are application changes the library layers can be re-used
+COPY --chown=185 target/quarkus-app/lib/ /deployments/lib/
+COPY --chown=185 target/quarkus-app/*.jar /deployments/
+COPY --chown=185 target/quarkus-app/app/ /deployments/app/
+COPY --chown=185 target/quarkus-app/quarkus/ /deployments/quarkus/
+
+EXPOSE 8080
+USER 185
+ENV JAVA_OPTS_APPEND="-Dquarkus.http.host=0.0.0.0 -Djava.util.logging.manager=org.jboss.logmanager.LogManager"
+ENV JAVA_APP_JAR="/deployments/quarkus-run.jar"
+
+ENTRYPOINT [ "/opt/jboss/container/java/run/run-java.sh" ]
diff --git a/auditlog/admin-service/src/main/docker/Dockerfile.native b/auditlog/admin-service/src/main/docker/Dockerfile.native
@@ -14,9 +14,14 @@
 # docker run -i --rm -p 8080:8080 quarkus/admin-service
 #
 ###
-FROM registry.access.redhat.com/ubi8/ubi-minimal
+FROM registry.access.redhat.com/ubi8/ubi-minimal:8.10
 WORKDIR /work/
-COPY target/*-runner /work/application
-RUN chmod 775 /work
+RUN chown 1001 /work \
+  && chmod "g+rwX" /work \
+  && chown 1001:root /work
+COPY --chown=1001:root --chmod=0755 target/*-runner /work/application
+
 EXPOSE 8080
-CMD ["./application", "-Dquarkus.http.host=0.0.0.0"]
+USER 1001
+
+ENTRYPOINT ["./application", "-Dquarkus.http.host=0.0.0.0"]
diff --git a/...og/admin-service/src/main/java/io/debezium/demos/auditing/admin/service/AdminService.java b/...og/admin-service/src/main/java/io/debezium/demos/auditing/admin/service/AdminService.java
@@ -1,54 +1,44 @@
 package io.debezium.demos.auditing.admin.service;
 
-import javax.annotation.PostConstruct;
-import javax.annotation.PreDestroy;
-import javax.enterprise.context.ApplicationScoped;
-import javax.inject.Inject;
-
+import org.kie.api.KieServices;
+import org.kie.api.runtime.KieContainer;
 import org.kie.api.runtime.KieSession;
-import org.kie.kogito.rules.KieRuntimeBuilder;
 
 import io.debezium.demos.auditing.admin.TransactionEvent;
 import io.debezium.demos.auditing.admin.VegetableEvent;
+import jakarta.annotation.PostConstruct;
+import jakarta.enterprise.context.ApplicationScoped;
 
 @ApplicationScoped
 public class AdminService {
 
-    @Inject
-    KieRuntimeBuilder kruntimeBuilder;
-
-    private KieSession workinMemory;
-
+    private KieContainer kContainer;
+
     @PostConstruct
     public void setup() {
-
-        this.workinMemory = kruntimeBuilder.newKieSession();
-    }
-
-    @PreDestroy
-    public void cleanup() {
-        this.workinMemory.dispose();
+        KieServices kieServices = KieServices.Factory.get();
+        this.kContainer = kieServices.getKieClasspathContainer();
     }
-    
-    public TransactionEvent processTransaction(TransactionEvent event) {
-        if (event == null) {
-            throw new RuntimeException("Missing transaction event");
+
+    public void processEvents(TransactionEvent tx, VegetableEvent veg) {
+        if (tx == null || veg == null) {
+            throw new IllegalArgumentException("Both TransactionEvent and VegetableEvent are required");
         }
-
-        workinMemory.insert(event);
-
-        workinMemory.fireAllRules();
-        return event;
-    }
 
-    public VegetableEvent processVegetable(VegetableEvent event) {
-        if (event == null) {
-            throw new RuntimeException("Missing transaction event");
+        KieSession session = null;
+
+        try {
+            session = kContainer.newKieSession();
+
+            session.insert(tx);
+            session.insert(veg);
+
+            session.fireAllRules();
+
+        } finally {
+            if (session != null) {
+                session.dispose();
+            }
         }
-
-        workinMemory.insert(event);
-
-        workinMemory.fireAllRules();
-        return event;
     }
-}
+}