feat: add ZooKeeper dual-active registry sync connector - #504

Open

weicao wants to merge 22 commits into

mainfrom

feat/zk-connector-interface

Commits on Jun 23, 2026

feat: add ZK connector interface draft — type definitions and empty implementation skeletons

authored and
Gina
committed
58dda4c
fix: address review feedback — add ExtractState/Syncer/Recovery to ZkExtractor, ZkRouter to ZkSinker

authored and
Gina
committed
49fea03
feat(zk): implement ZkSinker sink_raw with full ZK write logic

authored and
Gina
committed
99804e1
fix(zk-sinker): address review - LWW tie-break, NotEmpty, marker src_node

authored and
Gina
committed
1b3faf4
feat(zk): add ZkExtractor implementation (cherry-pick from Elizabeth)

authored and
Gina
committed
7eb1027
fix: resolve compilation errors from ZK connector additions

authored and
Gina
committed
9fefa89
test(zk): add dual ZK docker-compose and basic test config

authored and
Gina
committed
769981d
fix(zk-sinker): skip write when target data is unchanged

authored and
Gina
committed
819e349
fix(test): fix zk-dst ZOO_MY_ID and add dual-direction test configs

authored and
Gina
committed
9fd589e
feat(zk-sinker): add per-znode shadow metadata for proper LWW

authored and
Gina
committed
9432697
fix(zk): version+mzxid sync check for delete+recreate, cargo fmt

authored and
Gina
committed
b8381fa
fix(zk-sinker): update shadow metadata on skip-if-unchanged path

authored and
Gina
committed
767d4bc
fix: handle zk config in rdb topic router

wei
authored and
Gina
committed
0488c39
fix(zk): add ordered tombstone shadow handling

wei
authored and
Gina
committed
1834569
fix(zk): tighten tombstone lww ordering

wei
authored and
Gina
committed
7411bfb
feat(zk): add watch-triggered reconciliation loop

wei
authored and
Gina
committed
298e080
fix(zk): abort reconciliation on read uncertainty

wei
authored and
Gina
committed
a60f822
fix(zk): checkpoint reconciliation after staged entries

wei
authored and
Gina
committed
6b41e7c
fix(ci): restore rust 1.85 compatibility

wei
authored and
wei
committed
c1b4ea3

Commits on Jul 9, 2026

Merge remote-tracking branch 'origin/main' into pr504-conflict-resolution

wei
authored and
wei
committed
22029ba
Merge remote-tracking branch 'origin/main' into elizabeth/pr504-merge-main-20260709

wei
authored and
wei
committed
872e3a3
fix: format pr504 conflict resolution

wei
authored and
wei
committed
de88a91

Navigation Menu

Uh oh!

feat: add ZooKeeper dual-active registry sync connector - #504

feat: add ZooKeeper dual-active registry sync connector#504
weicao wants to merge 22 commits into
mainfrom
feat/zk-connector-interface

Commits on Jun 23, 2026

feat: add ZK connector interface draft — type definitions and empty implementation skeletons

fix: address review feedback — add ExtractState/Syncer/Recovery to ZkExtractor, ZkRouter to ZkSinker

feat(zk): implement ZkSinker sink_raw with full ZK write logic

fix(zk-sinker): address review - LWW tie-break, NotEmpty, marker src_node

feat(zk): add ZkExtractor implementation (cherry-pick from Elizabeth)

fix: resolve compilation errors from ZK connector additions

test(zk): add dual ZK docker-compose and basic test config

fix(zk-sinker): skip write when target data is unchanged

fix(test): fix zk-dst ZOO_MY_ID and add dual-direction test configs

feat(zk-sinker): add per-znode shadow metadata for proper LWW

fix(zk): version+mzxid sync check for delete+recreate, cargo fmt

fix(zk-sinker): update shadow metadata on skip-if-unchanged path

fix: handle zk config in rdb topic router

fix(zk): add ordered tombstone shadow handling

fix(zk): tighten tombstone lww ordering

feat(zk): add watch-triggered reconciliation loop

fix(zk): abort reconciliation on read uncertainty

fix(zk): checkpoint reconciliation after staged entries

fix(ci): restore rust 1.85 compatibility

Commits on Jul 9, 2026

Merge remote-tracking branch 'origin/main' into pr504-conflict-resolution

Merge remote-tracking branch 'origin/main' into elizabeth/pr504-merge-main-20260709

fix: format pr504 conflict resolution