Allow custom schema and data file paths, print file path on registeri…

…ng (#48)
cultureamp · Sep 10, 2024 · b9d803f · b9d803f
1 parent e8d9357
commit b9d803f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/plugins/debezium-server/bin/populate.ts b/plugins/debezium-server/bin/populate.ts
@@ -44,7 +44,7 @@ const registerSchema = async () => {
     type: SchemaType.AVRO,
     schema,
   });
-  console.log(`Auto-registered schema with id ${id}`);
+  console.log(`Auto-registered schema ${schemaPath} with id ${id}`);
 
   return id;
 };

diff --git a/plugins/debezium-server/plugin.json b/plugins/debezium-server/plugin.json
@@ -35,6 +35,8 @@
       "export OUTBOX_TABLE=outbox_table",
       "export HEARTBEAT_TABLE=debezium_heartbeat",
       "export TARGET_TOPIC=my_target_topic",
+      "export SCHEMA_PATH=com.cultureamp.test.user.v1-value.avsc",
+      "export SAMPLE_DATA_PATH=sample-data.json",
       "pnpm install -C {{.Virtenv}}"
     ],
     "scripts": {
@@ -57,8 +59,6 @@
         "kaf topic create _${FARM}.${INTERNAL_TOPIC_PREFIX}.debezium-heartbeat-table -p 1 -r 1 || true"
       ],
       "populate": [
-        "SCHEMA_PATH=com.cultureamp.test.user.v1-value.avsc \\",
-        "SAMPLE_DATA_PATH=sample-data.json \\",
         "pnpm run -C {{.Virtenv}} populate"
       ],
       "reset_offset": [