ibmstocktrader/trade-history Docker 镜像 - 轩辕镜像 | Docker 镜像高效稳定拉取服务

trade-history 镜像文档

镜像概述和主要用途

trade-history 是一个微服务镜像，核心功能是从 Kafka 消息队列读取数据，并将处理后的数据持久化存储到 MongoDB 数据库中。作为数据流转的中间层，该服务实现了消息消费与数据持久化的无缝衔接，适用于需要实时处理事件流并进行数据存储的场景。

核心功能和特性

• Kafka 消息消费：能够连接 Kafka 集群，订阅指定主题并消费消息
• MongoDB 数据写入：支持将消费的消息数据写入 MongoDB 数据库
• 轻量级微服务：设计简洁，专注于数据流转功能，易于集成到现有系统

使用场景和适用范围

• 实时事件流数据持久化
• 日志收集与存储
• ***交易记录处理
• 需要将 Kafka 事件数据持久化到 MongoDB 的业务场景

使用方法和配置说明

前提条件

• 已部署 Kafka 集群并可访问
• 已部署 MongoDB 数据库并可访问
• Docker 环境已安装

Docker 运行命令示例

docker
docker run -d \
  --name trade-history \
  -e KAFKA_BOOTSTRAP_SERVERS=kafka:9092 \
  -e KAFKA_TOPIC=trade-events \
  -e MONGO_URI=mongodb://mongo:27017/tradeDB \
  -e MONGO_COLLECTION=tradeHistory \
  ibmstocktrader/trade-history

Docker Compose 配置示例

yaml
version: '3'
services:
  trade-history:
    image: ibmstocktrader/trade-history
    container_name: trade-history
    environment:
      - KAFKA_BOOTSTRAP_SERVERS=kafka:9092
      - KAFKA_TOPIC=trade-events
      - MONGO_URI=mongodb://mongo:27017/tradeDB
      - MONGO_COLLECTION=tradeHistory
    depends_on:
      - kafka
      - mongo

环境变量配置说明

源码地址

更多详细信息和配置选项，请参考源码仓库：[***]