diff --git a/charts/gart/templates/debezium/configmap.yaml b/charts/gart/templates/debezium/configmap.yaml index 9e8e737..1ac4aad 100644 --- a/charts/gart/templates/debezium/configmap.yaml +++ b/charts/gart/templates/debezium/configmap.yaml @@ -37,7 +37,11 @@ data: "snapshot.mode": "always", {{- end }} {{- else }} - "snapshot.mode": "never", + {{- if eq .Values.dataconfig.dbType "mysql" }} + "snapshot.mode": "schema_only", + {{- else }} + "snapshot.mode": "no_data", + {{- end }} {{- end }} "database.server.id": "1", "include.schema.changes": "false", diff --git a/charts/gart/values.yaml b/charts/gart/values.yaml index 043b03d..d61fb92 100644 --- a/charts/gart/values.yaml +++ b/charts/gart/values.yaml @@ -151,7 +151,7 @@ debezium: replicaCount: 1 image: repository: debezium/connect - tag: latest + tag: 2.7.0.Final pullPolicy: IfNotPresent containerPort: 8083 resources: {} diff --git a/converter/parser.cc b/converter/parser.cc index b116cc7..47399d1 100644 --- a/converter/parser.cc +++ b/converter/parser.cc @@ -298,7 +298,6 @@ gart::Status TxnLogParser::parse(LogEntry& out, const string& log_str, // default for PostgreSQL, -1 for MySQL // TODO(SSJ): Hardcode for PostgreSQL and MySQL int tx_id = log["source"].value("txId", -1); - /* if (tx_id == -1) { // MySQL const json& gtid_json = log["source"]["gtid"]; @@ -314,7 +313,6 @@ gart::Status TxnLogParser::parse(LogEntry& out, const string& log_str, LOG(ERROR) << "Please open GTID for MySQL."; } } - */ out.tx_id = tx_id; diff --git a/scripts/install-deps.sh b/scripts/install-deps.sh index 13d725a..05779eb 100755 --- a/scripts/install-deps.sh +++ b/scripts/install-deps.sh @@ -296,7 +296,7 @@ database.user= database.password= database.include.list= table.include.list= -snapshot.mode= +snapshot.mode= $COMM_CONFIG