hailin
/
rwadurian
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
2,248 Commits 1 Branch 10 Tags 175 MiB
TypeScript 59.4%
Dart 20.3%
Go 7.3%
Kotlin 5.2%
Shell 3.7%
Other 3.9%
Go to file
hailin 5b1f4c82e6 fix(deploy): full-reset 时重建 1.0 source CDC connectors 以确保完整数据同步 
问题：
  执行 deploy-mining.sh full-reset 后，identity-postgres-connector 等 1.0 source
  CDC connectors 保留了旧的 Debezium offset 和 replication slot，导致 Debezium
  认为 initial snapshot 已完成而跳过重新快照。如果 connector 的 JSON 配置文件中
  新增了表（如 identity-connector.json 中的 wallet_addresses），这些表的存量数据
  永远不会被捕获到 Kafka topic，2.0 服务无法通过 CDC 同步到这些数据。

  具体表现：Kafka topic cdc.identity.public.wallet_addresses 始终为空（0条消息），
  2.0 auth-service 的 synced_wallet_addresses 表为空，用户 KAVA 地址未同步。

修复：
  在 full_reset() 的 Step 4 中，除了处理 outbox connectors，还新增了对 1.0 source
  CDC connectors (identity/referral/planting) 的处理：
  1. 删除 connector（释放 replication slot）
  2. 发送 tombstone 清除 debezium_offsets topic 中的偏移量
  3. 调用 pg_drop_replication_slot() 删除 PostgreSQL replication slot

  新增 Step 9：从 scripts/debezium/*.json 配置文件重新注册 source connectors，
  因为 offset 和 slot 都已清除，snapshot.mode=initial 会触发全新的 initial snapshot，
  确保所有配置表（包括新增的 wallet_addresses）的存量数据都被灌入 Kafka topic。

  总步骤数从 18 调整为 19。

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
 		2026-01-31 20:26:06 -08:00
.claude feat(mining-app): 二维码扫描支持从相册选择图片识别 2026-01-31 07:21:56 -08:00
backend fix(deploy): full-reset 时重建 1.0 source CDC connectors 以确保完整数据同步 2026-01-31 20:26:06 -08:00
contracts feat(blockchain): 部署 eUSDT 和 fUSDT 代币合约 2026-01-19 05:30:25 -08:00
docs docs: 添加 RWADurian 2.0 部署与运维成本方案 2026-01-22 03:29:51 -08:00
frontend revert(c2c): 还原C2C市场页资产概览为原始状态 2026-01-31 09:25:03 -08:00
kubernetes . 2025-11-25 10:29:24 +08:00
scripts fix(snapshot): 修改 Services PostgreSQL 用户名为 rwa_user 2026-01-08 09:05:22 -08:00
tests . 2025-11-25 10:29:24 +08:00
.gitignore feat(mining-ecosystem): 添加挖矿生态系统完整微服务与前端 2026-01-10 17:45:46 -08:00
README.md first commit 2025-11-23 21:21:44 -08:00
SEED01-qrcode.png fix: 短信超时返回成功状态避免前端报错 2025-12-21 20:55:31 -08:00
STKAITI.TTF feat(mobile-app): 添加合同签署 API 详细调试日志 2025-12-25 03:14:10 -08:00
contract.docx feat(kyc): 实名认证前检查手机号验证状态 2025-12-24 21:00:53 -08:00
docker-compose.yml first commit 2025-11-23 21:21:44 -08:00
挖矿.xlsx feat(contribution): 添加系统账户算力来源类型字段 2026-01-21 04:23:50 -08:00
榴莲皇后数据.xlsx fix(mobile-app): 修复多账号切换后账号列表只显示一个的问题 2025-12-27 11:12:50 -08:00
联合种植协议董事长_release_form.pdf fix(reporting-service): add /api/v1 prefix to wallet and reward service API calls 2026-01-04 23:18:10 -08:00

README.md