From 02027151ee936d2fc3fd6c9350dc3a4fd1c5b738 Mon Sep 17 00:00:00 2001
From: sweng66 <sweng@stanford.edu>
Date: Mon, 2 Dec 2024 09:24:41 -0800
Subject: [PATCH] reference_crud.py

---
 ...ostgres-source-mod-corpus-association.json | 26 +++++++++++++++++++
 1 file changed, 26 insertions(+)
 create mode 100644 debezium/postgres-source-mod-corpus-association.json

diff --git a/debezium/postgres-source-mod-corpus-association.json b/debezium/postgres-source-mod-corpus-association.json
new file mode 100644
index 000000000..b9d01272a
--- /dev/null
+++ b/debezium/postgres-source-mod-corpus-association.json
@@ -0,0 +1,26 @@
+{
+  "name": "postgres-source-mod-corpus-association",
+  "config": {
+    "connector.class": "io.debezium.connector.postgresql.PostgresConnector",
+    "tasks.max": "1",
+    "slot.name": "debezium_mod_corpus_association",
+    "publication.name": "debezium_mod_corpus_association",
+    "database.hostname": "${PSQL_HOST}",
+    "database.port": "${PSQL_PORT}",
+    "database.user": "${PSQL_USERNAME}",
+    "database.password": "${PSQL_PASSWORD}",
+    "database.dbname" : "${PSQL_DATABASE}",
+    "database.server.name": "abc",
+    "table.include.list": "public.mod_corpus_association",
+    "column.include.list": "mod_corpus_association_id, mod_id, reference_id, corpus, date_sorted_inside_corpus, updated_by",
+    "database.history.kafka.bootstrap.servers": "dbz_kafka:9092",
+    "decimal.handling.mode" : "string",
+    "poll.interval.ms": "100",
+    "transforms": "extractKey,extractValue",
+    "transforms.extractKey.field": "mod_corpus_association_id",
+    "transforms.extractKey.type": "org.apache.kafka.connect.transforms.ExtractField$Key",
+    "transforms.extractValue.field": "after",
+    "transforms.extractValue.type": "org.apache.kafka.connect.transforms.ExtractField$Value",
+    "plugin.name": "pgoutput"
+  }
+}