XuJiacheng a954db752f feat: 实现RCU升级后端服务初始版本 ...

- 添加Kafka消费者组件用于消费升级事件数据
- 实现数据处理器进行数据验证和转换
- 添加数据库写入组件支持批量写入G5数据库
- 配置环境变量管理连接参数
- 添加日志记录和错误处理机制
- 实现优雅关闭和流控功能

2026-03-17 19:23:51 +08:00

..

config

feat: 实现RCU升级后端服务初始版本

2026-03-17 19:23:51 +08:00

db

feat: 实现RCU升级后端服务初始版本

2026-03-17 19:23:51 +08:00

kafka

feat: 实现RCU升级后端服务初始版本

2026-03-17 19:23:51 +08:00

processor

feat: 实现RCU升级后端服务初始版本

2026-03-17 19:23:51 +08:00

utils

feat: 实现RCU升级后端服务初始版本

2026-03-17 19:23:51 +08:00

index.js

feat: 实现RCU升级后端服务初始版本

2026-03-17 19:23:51 +08:00

test-consumer.js

feat: 实现RCU升级后端服务初始版本

2026-03-17 19:23:51 +08:00