Files
XuJiacheng 8337c60f98 feat: 实现Kafka批量消费与写入以提升吞吐量
引入批量处理机制,将消息缓冲并按批次写入数据库,显著提高消费性能。调整Kafka配置参数,优化消费者并发与提交策略。新增分区索引自动创建功能,并重构处理器以支持批量操作。添加降级写入逻辑以处理数据错误,同时增强指标收集以监控批量处理效果。
2026-02-09 10:50:56 +08:00
..

bls-onoffline-backend

安装与运行

  • Node.js 22+
  • npm install
  • npm run dev

构建与测试

  • npm run build
  • npm run test
  • npm run lint

规范校验

  • npm run spec:lint
  • npm run spec:validate

环境变量

  • 复制 .env.example 为 .env 并按实际环境配置

数据库初始化

  • 启动时自动执行 scripts/init_db.sql 并预创建未来 30 天分区

规范说明

  • 规格文件位于 spec/onoffline-spec.md