Quality of life fixes

ethho · Dec 28, 2023 · 48a6319 · 48a6319
1 parent 092c294
commit 48a6319
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 6 deletions.
diff --git a/debezium-config/application.properties b/debezium-config/application.properties
@@ -12,7 +12,7 @@ debezium.sink.rabbitmq.routingKeyDurable=true
 # Source connector
 debezium.source.connector.class=io.debezium.connector.mysql.MySqlConnector
 debezium.source.schema.history.internal=io.debezium.relational.history.MemorySchemaHistory
-# database.history.file.filename=history.dat
+database.history.file.filename=history.dat
 debezium.source.offset.storage.file.filename=offsets.dat
 debezium.source.offset.flush.interval.ms=0
 debezium.source.schema.whitelist=djtest_university
@@ -31,9 +31,17 @@ debezium.source.database.user=root
 debezium.source.database.password=password
 debezium.source.database.dbname=djtest_university
 debezium.source.database.server.name=fakeservices.datajoint.io
-# Check uniqueness: mysql -hfakeservices.datajoint.io -uroot -ppassword -e 'SHOW SLAVE HOSTS;'
+# Check uniqueness of slave ID: mysql -hfakeservices.datajoint.io -uroot -ppassword -e 'SHOW SLAVE HOSTS;'
 debezium.source.database.server.id=184054
 # debezium.source.database.encrypt=false
 debezium.source.database.allowPublicKeyRetrieval=true
-debezium.source.database.history=io.debezium.relational.history.MemorySchemaHistory
-debezium.source.snapshot.mode=schema_only_recovery
+debezium.source.database.history=io.debezium.storage.file.history.FileSchemaHistory
+debezium.source.schema.history.internal.file.filename=schema_history.dat
+
+# Snapshot properties: use schema_only_recovery when indicated in ERROR logs
+debezium.source.snapshot.mode=when_needed
+# debezium.source.snapshot.mode=schema_only_recovery
+
+# Use minimal_percona for Percona cluster
+debezium.source.snapshot.locking.mode=minimal
+# debezium.source.snapshot.locking.mode=minimal_percona
diff --git a/tests/test_university.py b/tests/test_university.py
@@ -179,10 +179,10 @@ def test_indefinite(schema_uni):
     while True:
         Department().insert1(
             dict(
-                dept=f"FOO{i}",
+                dept=str(i),
                 dept_name="foobar",
                 dept_address="my address",
-                dept_phone="000000000",
+                dept_phone=str(i),
             ),
             skip_duplicates=True,
         )