Non-ASCII unicode characters are encoded incorrectly

[jun-ke]

Hello

When replicating from scratch, non-ascii characters (cyrillic, for example) transfered to clickhouse correctly, but when a new row added in MySQL after initial replication is finished, in Clickhouse symbols are saved like '\uffffffd0\uffffff91'.

For example, field in MySQL:
"some_text:Б" -- "Б" is U+0411

in Clickhouse it appears as:
"some_text:\uffffffd0\uffffff91"

When replicating from scratch, problem doesn't appear, it's only on real-time replication

In MySQL character set is 'utf8mb4'

[jun-ke]

Sorry, i missed the important part: in MySQL column type is JSON.
Regular varchar are syncing correctly

[bakwc]

Not reproducing. Write the exact steps i should do to reproduce it, also post mysql config file my.cnf.

[jun-ke]

my.cnf:

[mysqld]
user            = mysql

bind-address            = 0.0.0.0
mysqlx-bind-address     = 0.0.0.0

key_buffer_size         = 16M

myisam-recover-options  = BACKUP

log_error = /var/log/mysql/error.log

gtid_mode = on
enforce_gtid_consistency = 1
binlog_expire_logs_seconds = 864000
max_binlog_size            = 500M
binlog_format              = ROW

Steps to reproduce it:

1. Create table:

CREATE TABLE `table1` (
  `id` bigint unsigned NOT NULL AUTO_INCREMENT,
  `name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci DEFAULT NULL,
  `json_data` json DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;

2. Insert some data:

insert into `table1` (`name`, `json_data`) VALUES ('Текст1', '{"int": 1, "text": "Текст1"}');
insert into `table1` (`name`, `json_data`) VALUES ('Текст2', '{"int": 2, "text": "Текст2"}');

3. run replicator

4. after initial replication is complete, add some rows:

insert into `table1` (`name`, `json_data`) VALUES ('Текст3', '{"int": 3, "text": "Текст3"}');

in clickhouse content of the table1:

id|name  |json_data                                                                                                                  |_version|
--+------+---------------------------------------------------------------------------------------------------------------------------+--------+
 1|Текст1|{"int": 1, "text": "Текст1"}                                                                                               |       1|
 2|Текст2|{"int": 2, "text": "Текст2"}                                                                                               |       2|
 3|Текст3|{"int": 3, "text": "\uffffffd0\uffffffa2\uffffffd0\uffffffb5\uffffffd0\uffffffba\uffffffd1\uffffff81\uffffffd1\uffffff823"}|       4|

mysql version 8.0.41

[bakwc]

not_reproduced.mov

For me it's still not reproducing.

1. Using mysql cli I could not insert non-ascii characters at all.
2. Using sequel ace everyting inserts and replicates as expected.

[bazhanius]

Don't know if it's ASCII problem. We reproducing it with json which contains cyrillic letters on every updates.

Real example:

1. json field in MySQL ["2А", "2Э", "2Т", "2Ф", "2Х", "2Б", "2Ц", "2Р", "2Ю"]
2. run one-time data copy works fine, in ClickHouse it will be the same ["2А", "2Э", "2Т", "2Ф", "2Х", "2Б", "2Ц", "2Р", "2Ю"]
3. then enable realtime data sync
4. add "1Ж" in mysql field → ["2А", "2Э", "2Т", "2Ф", "2Х", "2Б", "2Ц", "2Р", "2Ю", "1Ж"]
5. wait for realtime sync and in clickhouse it will be broken
   ["2\uffffffd0\uffffff90", "2\uffffffd0\uffffffad", "2\uffffffd0\uffffffa2", "2\uffffffd0\uffffffa4", "2\uffffffd0\uffffffa5", "2\uffffffd0\uffffff91", "2\uffffffd0\uffffffa6", "2\uffffffd0\uffffffa0", "2\uffffffd0\uffffffae", "1\uffffffd0\uffffff96"]

Seems like real time function finding json diff brokes something.

[bakwc]

Maybe it's something OS specific.. Do you use it in docker or native? What exact os do you use? What locale do you have?

[mustdieku]

I ran the test environment using:

docker compose -f docker-compose-tests.yaml up

Then executed the test with UTF-8 characters:

docker exec -w /app/ -it mysql_ch_replicator-replicator-1 python3 -m pytest -v -s test_mysql_ch_replicator.py -k test_json2

Test code:

def test_json2():
    cfg = config.Settings()
    cfg.load(CONFIG_FILE)

    mysql = mysql_api.MySQLApi(
        database=None,
        mysql_settings=cfg.mysql,
    )

    ch = clickhouse_api.ClickhouseApi(
        database=TEST_DB_NAME,
        clickhouse_settings=cfg.clickhouse,
    )

    prepare_env(cfg, mysql, ch)

    mysql.execute("SET sql_mode = 'ALLOW_INVALID_DATES';")

    mysql.execute(f'''
CREATE TABLE `{TEST_TABLE_NAME}` (
    `id` int unsigned NOT NULL AUTO_INCREMENT,
    name varchar(255),
    data json,
    PRIMARY KEY (id)
); 
    ''')

    mysql.execute(
        f"INSERT INTO `{TEST_TABLE_NAME}` (name, data) VALUES " +
        """('Ivan', '{"а": "б", "в": [1,2,3]}');""",
        commit=True,
    )

    binlog_replicator_runner = BinlogReplicatorRunner()
    binlog_replicator_runner.run()
    db_replicator_runner = DbReplicatorRunner(TEST_DB_NAME)
    db_replicator_runner.run()

    assert_wait(lambda: TEST_DB_NAME in ch.get_databases())

    ch.execute_command(f'USE `{TEST_DB_NAME}`')

    assert_wait(lambda: TEST_TABLE_NAME in ch.get_tables())
    assert_wait(lambda: len(ch.select(TEST_TABLE_NAME)) == 1)

    mysql.execute(
        f"INSERT INTO `{TEST_TABLE_NAME}` (name, data) VALUES " +
        """('Peter', '{"в": "б", "а": [3,2,1]}');""",
        commit=True,
    )
    assert_wait(lambda: len(ch.select(TEST_TABLE_NAME)) == 2)

    assert json.loads(ch.select(TEST_TABLE_NAME, "name='Ivan'")[0]['data'])['в'] == [1, 2, 3]
    assert json.loads(ch.select(TEST_TABLE_NAME, "name='Peter'")[0]['data'])['в'] == [3, 2, 1]
    db_replicator_runner.stop()
    binlog_replicator_runner.stop()

However, the test fails with the following error:

AssertionError: assert '\uffffffd0\uffffffb1' == [3, 2, 1]

It seems that the second JSON row ({"в": "б", "а": [3,2,1]}) was not replicated correctly. The field в is expected to be an array, but what ends up in ClickHouse is a corrupted string instead.

[bakwc]

assert json.loads(ch.select(TEST_TABLE_NAME, "name='Peter'")[0]['data'])['в'] == [3, 2, 1]

Sorry, but why do you expect 'в'key be equal to [3, 2, 1]?
A few lines higher you inserted a following data: """('Peter', '{"в": "б", "а": [3,2,1]}');""". It's clearly seen that you inserted "в" key with a value "б". So your assert statement for Peter is incorrect, it should be following:

assert json.loads(ch.select(TEST_TABLE_NAME, "name='Peter'")[0]['data'])['в'] == 'б'

So the full test code is:

def test_json2():
    cfg = config.Settings()
    cfg.load(CONFIG_FILE)

    mysql = mysql_api.MySQLApi(
        database=None,
        mysql_settings=cfg.mysql,
    )

    ch = clickhouse_api.ClickhouseApi(
        database=TEST_DB_NAME,
        clickhouse_settings=cfg.clickhouse,
    )

    prepare_env(cfg, mysql, ch)

    mysql.execute("SET sql_mode = 'ALLOW_INVALID_DATES';")

    mysql.execute(f'''
CREATE TABLE `{TEST_TABLE_NAME}` (
    `id` int unsigned NOT NULL AUTO_INCREMENT,
    name varchar(255),
    data json,
    PRIMARY KEY (id)
); 
    ''')

    mysql.execute(
        f"INSERT INTO `{TEST_TABLE_NAME}` (name, data) VALUES " +
        """('Ivan', '{"а": "б", "в": [1,2,3]}');""",
        commit=True,
    )

    binlog_replicator_runner = BinlogReplicatorRunner()
    binlog_replicator_runner.run()
    db_replicator_runner = DbReplicatorRunner(TEST_DB_NAME)
    db_replicator_runner.run()

    assert_wait(lambda: TEST_DB_NAME in ch.get_databases())

    ch.execute_command(f'USE `{TEST_DB_NAME}`')

    assert_wait(lambda: TEST_TABLE_NAME in ch.get_tables())
    assert_wait(lambda: len(ch.select(TEST_TABLE_NAME)) == 1)

    mysql.execute(
        f"INSERT INTO `{TEST_TABLE_NAME}` (name, data) VALUES " +
        """('Peter', '{"в": "б", "а": [3,2,1]}');""",
        commit=True,
    )
    assert_wait(lambda: len(ch.select(TEST_TABLE_NAME)) == 2)

    assert json.loads(ch.select(TEST_TABLE_NAME, "name='Ivan'")[0]['data'])['в'] == [1, 2, 3]
    assert json.loads(ch.select(TEST_TABLE_NAME, "name='Peter'")[0]['data'])['в'] == 'б'
    db_replicator_runner.stop()
    binlog_replicator_runner.stop()

On my machine the fixed test is passing. Could you please check if it's passing on your machine too?
I would be glad to fix the issue but I need some help with debugging / reproducing, as on my machine it's not reproduced (

[mustdieku]

Test Details

============================================================================================================================= test session starts ==============================================================================================================================
platform linux -- Python 3.12.10, pytest-8.4.1, pluggy-1.6.0 -- /usr/local/bin/python3
cachedir: .pytest_cache
rootdir: /app
configfile: pytest.ini
plugins: anyio-4.7.0
collected 46 items / 45 deselected / 1 selected

test_mysql_ch_replicator.py::test_json2 [binlogrepl 2025-07-02 21:32:45,831 INFO] state start position: None
[binlogrepl 2025-07-02 21:32:45,843 INFO] connection_settings: {'host': 'localhost', 'port': 9306, 'user': 'root', 'passwd': 'admin', 'charset': 'utf8'}
[binlogrepl 2025-07-02 21:32:45,843 INFO] resume_stream: True
[binlogrepl 2025-07-02 21:32:45,844 INFO] allowed_events_in_packet: [event, event, event, event, row_event, row_event, row_event, event, row_event, event, event, event, event, event, event, event, event, event, row_event, event, event, event, event, event]
[binlogrepl 2025-07-02 21:32:45,845 INFO] server_id: 264324880
[binlogrepl 2025-07-02 21:32:45,943 DEBUG] received event <class 'mysql_ch_replicator.pymysqlreplication.event.RotateEvent'>, ('mysql-bin.000003', 1361)
[binlogrepl 2025-07-02 21:32:45,943 DEBUG] received event <class 'mysql_ch_replicator.pymysqlreplication.event.FormatDescriptionEvent'>, ('mysql-bin.000003', 1361)
[dbrepl replication-test_db 2025-07-02 21:32:45,978 INFO] launched db_replicator
[dbrepl replication-test_db 2025-07-02 21:32:45,989 INFO] recreating database
[dbrepl replication-test_db 2025-07-02 21:32:46,009 INFO] last known transaction None
[dbrepl replication-test_db 2025-07-02 21:32:46,028 DEBUG] create table query:
CREATE TABLE IF NOT EXISTS replication-test_db_tmp.test_table
(
id UInt32,
name Nullable(String),
data Nullable(String),
_version UInt64,
INDEX _version _version TYPE minmax GRANULARITY 1,
INDEX idx_id id TYPE bloom_filter GRANULARITY 1
)
ENGINE = ReplacingMergeTree(_version)
PARTITION BY intDiv(id, 4294967)
ORDER BY id
SETTINGS index_granularity = 8192

[dbrepl replication-test_db 2025-07-02 21:32:46,044 INFO] running initial replication
[dbrepl replication-test_db 2025-07-02 21:32:46,045 INFO] running initial replication for table test_table
[dbrepl replication-test_db 2025-07-02 21:32:46,045 INFO] replicating from scratch
[dbrepl replication-test_db 2025-07-02 21:32:46,046 DEBUG] mysql table structure: TableStructure(fields=[TableField(name='id', field_type='int', parameters='unsigned NOT NULL AUTO_INCREMENT', additional_data=None), TableField(name='name', field_type='varchar(255)', parameters='DEFAULT NULL', additional_data=None), TableField(name='data', field_type='json', parameters='DEFAULT NULL', additional_data=None)], primary_keys=['id'], primary_key_ids=[0], table_name='test_table', charset='utf8mb4', charset_python='utf_8', if_not_exists=False)
[dbrepl replication-test_db 2025-07-02 21:32:46,046 DEBUG] clickhouse table structure: TableStructure(fields=[TableField(name='id', field_type='UInt32', parameters='', additional_data=None), TableField(name='name', field_type='Nullable(String)', parameters='', additional_data=None), TableField(name='data', field_type='Nullable(String)', parameters='', additional_data=None)], primary_keys=['id'], primary_key_ids=[0], table_name='test_table', charset='', charset_python='', if_not_exists=True)
[dbrepl replication-test_db 2025-07-02 21:32:46,047 DEBUG] extracted 1 records from mysql
[dbrepl replication-test_db 2025-07-02 21:32:46,047 DEBUG] records: [(1, 'Ivan', '{"а": "б", "в": [1, 2, 3]}')]
[dbrepl replication-test_db 2025-07-02 21:32:46,058 DEBUG] Context insert response code: 200, content: b''
[dbrepl replication-test_db 2025-07-02 21:32:46,059 INFO] touch binlog /app/binlog/replication-test_db
[dbrepl replication-test_db 2025-07-02 21:32:46,060 DEBUG] extracted 0 records from mysql
[dbrepl replication-test_db 2025-07-02 21:32:46,060 DEBUG] records: []
[dbrepl replication-test_db 2025-07-02 21:32:46,060 INFO] finish replicating test_table, replicated 1 records, primary key: [1]
[dbrepl replication-test_db 2025-07-02 21:32:46,061 INFO] Verifying table structures after initial replication
[dbrepl replication-test_db 2025-07-02 21:32:46,072 INFO] Table structure verification passed for test_table
[dbrepl replication-test_db 2025-07-02 21:32:46,073 INFO] Table structure verification completed
[dbrepl replication-test_db 2025-07-02 21:32:46,073 INFO] initial replication - swapping database
[dbrepl replication-test_db 2025-07-02 21:32:46,081 INFO] initial replication - done
[dbrepl replication-test_db 2025-07-02 21:32:46,082 INFO] running realtime replication from the position: None
[dbrepl replication-test_db 2025-07-02 21:32:46,082 INFO] set position - no files found
[binlogrepl 2025-07-02 21:32:46,248 DEBUG] received event <class 'mysql_ch_replicator.pymysqlreplication.event.RotateEvent'>, ('mysql-bin.000003', 1361)
[binlogrepl 2025-07-02 21:32:46,248 DEBUG] received event <class 'mysql_ch_replicator.pymysqlreplication.event.FormatDescriptionEvent'>, ('mysql-bin.000003', 1361)
[binlogrepl 2025-07-02 21:32:46,248 DEBUG] received event <class 'mysql_ch_replicator.pymysqlreplication.event.GtidEvent'>, ('mysql-bin.000003', 1440)
[binlogrepl 2025-07-02 21:32:46,248 DEBUG] received event <class 'mysql_ch_replicator.pymysqlreplication.event.QueryEvent'>, ('mysql-bin.000003', 1530)
[binlogrepl 2025-07-02 21:32:46,249 DEBUG] event matched ('mysql-bin.000003', 1530), replication-test_db,
[binlogrepl 2025-07-02 21:32:46,249 DEBUG] store event ('mysql-bin.000003', 1530), event type: 3, database: replication-test_db table: records: BEGIN
[binlogrepl 2025-07-02 21:32:46,249 DEBUG] store event ('mysql-bin.000003', 1530)
[binlogrepl 2025-07-02 21:32:46,249 DEBUG] received event <class 'mysql_ch_replicator.pymysqlreplication.row_event.TableMapEvent'>, ('mysql-bin.000003', 1611)
[binlogrepl 2025-07-02 21:32:46,250 DEBUG] received event <class 'mysql_ch_replicator.pymysqlreplication.row_event.WriteRowsEvent'>, ('mysql-bin.000003', 1701)
[binlogrepl 2025-07-02 21:32:46,250 DEBUG] event matched ('mysql-bin.000003', 1701), replication-test_db, test_table
[binlogrepl 2025-07-02 21:32:46,250 DEBUG] store event ('mysql-bin.000003', 1701), event type: 1, database: replication-test_db table: test_table records: [[2, b'Peter', '{"а": [3, 2, 1], "в": "\uffffffd0\uffffffb1"}']]
[binlogrepl 2025-07-02 21:32:46,250 DEBUG] store event ('mysql-bin.000003', 1701)
[binlogrepl 2025-07-02 21:32:46,250 DEBUG] received event <class 'mysql_ch_replicator.pymysqlreplication.event.XidEvent'>, ('mysql-bin.000003', 1732)
[dbrepl replication-test_db 2025-07-02 21:32:46,385 DEBUG] upload records, to insert: 0, to delete: 0
[dbrepl replication-test_db 2025-07-02 21:32:46,386 INFO] stats: {"last_transaction": null, "events_count": 0, "insert_events_count": 0, "insert_records_count": 0, "erase_events_count": 0, "erase_records_count": 0, "no_events_count": 1, "cpu_load": 0.0}
[dbrepl replication-test_db 2025-07-02 21:32:46,386 INFO] ch_stats: {"total": {"inserts": {"duration": 0.012, "events": 1, "records": 1}, "erases": {"duration": 0.0, "events": 0, "records": 0}}, "test_table": {"inserts": {"duration": 0.012, "events": 1, "records": 1}, "erases": {"duration": 0.0, "events": 0, "records": 0}}}
[dbrepl replication-test_db 2025-07-02 21:32:46,386 DEBUG] processing event ('mysql-bin.000003', 1530), 3,
[dbrepl replication-test_db 2025-07-02 21:32:46,386 DEBUG] processing query event: ('mysql-bin.000003', 1530), query: BEGIN
[dbrepl replication-test_db 2025-07-02 21:32:46,386 DEBUG] processing event ('mysql-bin.000003', 1701), 1, test_table
[dbrepl replication-test_db 2025-07-02 21:32:46,386 DEBUG] processing insert event: ('mysql-bin.000003', 1701), table: test_table, records: [[2, b'Peter', '{"а": [3, 2, 1], "в": "\uffffffd0\uffffffb1"}']]
[binlogrepl 2025-07-02 21:32:46,557 DEBUG] received event <class 'mysql_ch_replicator.pymysqlreplication.event.RotateEvent'>, ('mysql-bin.000003', 1732)
[binlogrepl 2025-07-02 21:32:46,557 DEBUG] received event <class 'mysql_ch_replicator.pymysqlreplication.event.FormatDescriptionEvent'>, ('mysql-bin.000003', 1732)
[binlogrepl 2025-07-02 21:32:46,863 DEBUG] received event <class 'mysql_ch_replicator.pymysqlreplication.event.RotateEvent'>, ('mysql-bin.000003', 1732)
[binlogrepl 2025-07-02 21:32:46,863 DEBUG] received event <class 'mysql_ch_replicator.pymysqlreplication.event.FormatDescriptionEvent'>, ('mysql-bin.000003', 1732)
[binlogrepl 2025-07-02 21:32:47,177 DEBUG] received event <class 'mysql_ch_replicator.pymysqlreplication.event.RotateEvent'>, ('mysql-bin.000003', 1732)
[binlogrepl 2025-07-02 21:32:47,177 DEBUG] received event <class 'mysql_ch_replicator.pymysqlreplication.event.FormatDescriptionEvent'>, ('mysql-bin.000003', 1732)
[binlogrepl 2025-07-02 21:32:47,481 DEBUG] received event <class 'mysql_ch_replicator.pymysqlreplication.event.RotateEvent'>, ('mysql-bin.000003', 1732)
[binlogrepl 2025-07-02 21:32:47,481 DEBUG] received event <class 'mysql_ch_replicator.pymysqlreplication.event.FormatDescriptionEvent'>, ('mysql-bin.000003', 1732)
[dbrepl replication-test_db 2025-07-02 21:32:47,587 DEBUG] upload records, to insert: 2, to delete: 2
[dbrepl replication-test_db 2025-07-02 21:32:47,587 DEBUG] inserting into test_table, records: dict_values([(2, 'Peter', '{"а": [3, 2, 1], "в": "\uffffffd0\uffffffb1"}')])
[dbrepl replication-test_db 2025-07-02 21:32:47,595 DEBUG] Context insert response code: 200, content: b''
FAILED

=================================================================================================================================== FAILURES ===================================================================================================================================
__________________________________________________________________________________________________________________________________ test_json2 __________________________________________________________________________________________________________________________________

def test_json2():
    cfg = config.Settings()
    cfg.load(CONFIG_FILE)

    mysql = mysql_api.MySQLApi(
        database=None,
        mysql_settings=cfg.mysql,
    )

    ch = clickhouse_api.ClickhouseApi(
        database=TEST_DB_NAME,
        clickhouse_settings=cfg.clickhouse,
    )

    prepare_env(cfg, mysql, ch)

    mysql.execute("SET sql_mode = 'ALLOW_INVALID_DATES';")

    mysql.execute(f'''
CREATE TABLE `{TEST_TABLE_NAME}` (
    `id` int unsigned NOT NULL AUTO_INCREMENT,
    name varchar(255),
    data json,
    PRIMARY KEY (id)
);
    ''')

    mysql.execute(
        f"INSERT INTO `{TEST_TABLE_NAME}` (name, data) VALUES " +
        """('Ivan', '{"а": "б", "в": [1,2,3]}');""",
        commit=True,
    )

    binlog_replicator_runner = BinlogReplicatorRunner()
    binlog_replicator_runner.run()
    db_replicator_runner = DbReplicatorRunner(TEST_DB_NAME)
    db_replicator_runner.run()

    assert_wait(lambda: TEST_DB_NAME in ch.get_databases())

    ch.execute_command(f'USE `{TEST_DB_NAME}`')

    assert_wait(lambda: TEST_TABLE_NAME in ch.get_tables())
    assert_wait(lambda: len(ch.select(TEST_TABLE_NAME)) == 1)

    mysql.execute(
        f"INSERT INTO `{TEST_TABLE_NAME}` (name, data) VALUES " +
        """('Peter', '{"в": "б", "а": [3,2,1]}');""",
        commit=True,
    )
    assert_wait(lambda: len(ch.select(TEST_TABLE_NAME)) == 2)

    assert json.loads(ch.select(TEST_TABLE_NAME, "name='Ivan'")[0]['data'])['в'] == [1, 2, 3]

  assert json.loads(ch.select(TEST_TABLE_NAME, "name='Peter'")[0]['data'])['в'] == [3, 2, 1]

E AssertionError: assert '\uffffffd0\uffffffb1' == [3, 2, 1]

test_mysql_ch_replicator.py:2804: AssertionError
=========================================================================================================================== short test summary info ============================================================================================================================
FAILED test_mysql_ch_replicator.py::test_json2 - AssertionError: assert '\uffffffd0\uffffffb1' == [3, 2, 1]
======================================================================================================================= 1 failed, 45 deselected in 6.25s =======================================================================================================================
[binlogrepl 2025-07-02 21:32:47,906 DEBUG] received event <class 'mysql_ch_replicator.pymysqlreplication.event.RotateEvent'>, ('mysql-bin.000003', 1732)
[binlogrepl 2025-07-02 21:32:47,906 DEBUG] received event <class 'mysql_ch_replicator.pymysqlreplication.event.FormatDescriptionEvent'>, ('mysql-bin.000003', 1732)
[binlogrepl 2025-07-02 21:32:48,339 DEBUG] received event <class 'mysql_ch_replicator.pymysqlreplication.event.RotateEvent'>, ('mysql-bin.000003', 1732)
[binlogrepl 2025-07-02 21:32:48,339 DEBUG] received event <class 'mysql_ch_replicator.pymysqlreplication.event.FormatDescriptionEvent'>, ('mysql-bin.000003', 1732)
[binlogrepl 2025-07-02 21:32:48,643 INFO] stopping binlog_replicator
[binlogrepl 2025-07-02 21:32:48,644 INFO] stopped
[dbrepl replication-test_db 2025-07-02 21:32:48,800 DEBUG] upload records, to insert: 0, to delete: 0
[dbrepl replication-test_db 2025-07-02 21:32:49,101 INFO] stopping db_replicator
[dbrepl replication-test_db 2025-07-02 21:32:49,101 DEBUG] upload records, to insert: 0, to delete: 0
[dbrepl replication-test_db 2025-07-02 21:32:49,102 INFO] stopped

[bakwc]

Thanks a lot! Was able to reproduce in github CI. Will prepare a fix.

[bakwc]

Fixed in v0.0.90 release