DBZ-8459 Add transforms and predicates into example

Signed-off-by: Fiore Mario Vitale <[email protected]>

debezium-platform-conductor/src/main/resources/application.yml

@@ -102,9 +102,9 @@ quarkus:
   quarkus:
     debezium-outbox:
       remove-after-insert: false
-    hibernate-orm:
-      database:
-        generation: drop-and-create
+    flyway:
+      baseline-on-migrate: true
+      migrate-at-start: true
     datasource:
       devservices:
         enabled: true

debezium-platform-conductor/src/main/resources/db/migration/V0.1.0__initial_database.sql

@@ -75,6 +75,9 @@ create table transform (
     schema varchar(255) not null,
     type varchar(255) not null,
     config jsonb,
+    predicate_type VARCHAR(255),
+    predicate_config JSONB,
+    predicate_negate BOOLEAN,
     primary key (id)
 );
 

examples/payloads/pipeline.json

@@ -9,5 +9,11 @@
     "id": 1,
     "name": "test-destination"
   },
+  "transforms": [
+    {
+      "name": "ExtractRecords",
+      "id": 1
+    }
+  ],
   "logLevel": "debug"
 }

examples/payloads/transform.json

@@ -0,0 +1,19 @@
+{
+  "name": "Debezium marker",
+  "description": "Extract Debezium payload",
+  "type": "io.debezium.transforms.ExtractNewRecordState",
+  "schema": "string",
+  "vaults": [
+  ],
+  "config": {
+    "add.fields": "op",
+    "add.headers": "db,table"
+  },
+  "predicate": {
+    "type": "org.apache.kafka.connect.transforms.predicates.TopicNameMatches",
+    "config": {
+      "pattern": "inventory.inventory.products"
+    },
+    "negate": false
+  }
+}

examples/seed.sh

@@ -3,4 +3,5 @@ port=${2:-8080}
 payloads_dir=${3:-payloads}
 http POST ${url}:${port}/api/sources @${payloads_dir}/source.json
 http POST ${url}:${port}/api/destinations @${payloads_dir}/destination.json
+http POST ${url}:${port}/api/transforms @${payloads_dir}/transform.json
 http POST ${url}:${port}/api/pipelines @${payloads_dir}/pipeline.json