hailin
/
rwadurian
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
rwadurian/backend/services/identity-service/src/infrastructure/kafka
History
hailin 05a9ca31f6 feat(identity): 实现 Outbox 模式事件发布 
## 概述
为 identity-service 实现 Outbox 模式，确保数据库事务和 Kafka 事件发布的原子性。

## 新增表
- OutboxEvent: 事件暂存表，用于事务性事件发布

## 新增组件
- OutboxRepository: Outbox 事件持久化
- OutboxPublisherService: 轮询发布未处理事件到 Kafka

## 支持的事件
- identity.UserAccountCreated: 用户注册事件
- identity.UserAccountAutoCreated: 自动创建用户事件

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
 		2025-12-18 00:29:40 -08:00
..
blockchain-event-consumer.service.ts feat: 暂时禁用 BSC 链，添加 Kafka 企业级重试配置 2025-12-15 22:33:34 -08:00
dead-letter.service.ts refactor(mpc-system): migrate to party-driven architecture with PartyID-based routing 2025-12-05 08:11:28 -08:00
event-consumer.controller.ts refactor(mpc-system): migrate to party-driven architecture with PartyID-based routing 2025-12-05 08:11:28 -08:00
event-publisher.service.ts feat: add detailed debug logging for MPC Kafka event flow 2025-12-06 19:49:06 -08:00
event-retry.service.ts refactor(mpc-system): migrate to party-driven architecture with PartyID-based routing 2025-12-05 08:11:28 -08:00
index.ts feat: move address derivation from identity-service to blockchain-service 2025-12-06 21:08:21 -08:00
kafka.module.ts feat(identity): 实现 Outbox 模式事件发布 2025-12-18 00:29:40 -08:00
mpc-event-consumer.service.ts feat: 暂时禁用 BSC 链，添加 Kafka 企业级重试配置 2025-12-15 22:33:34 -08:00
outbox-publisher.service.ts feat(identity): 实现 Outbox 模式事件发布 2025-12-18 00:29:40 -08:00