eucm/rage-analytics-realtime

实时分析模块（Analytics Realtime）

镜像概述

该镜像为RAGE Analytics平台的核心实时处理组件，基于Apache Storm拓扑实现，专注于游戏产生的分析轨迹数据的实时处理。它从Kafka队列获取输入数据，通过Storm Trident进行流计算，并将处理结果持久化到ElasticSearch，为后续的Kibana可视化提供数据支持。

核心功能

1. Kafka数据读取：从指定Kafka主题接收游戏轨迹数据
2. 实时流计算：基于Apache Storm Trident实现高效的实时数据处理逻辑
3. ElasticSearch持久化：将处理后的结果存储到ElasticSearch索引
4. 可扩展性：支持自定义分析逻辑扩展，满足不同游戏场景的需求

使用场景

• 教育游戏/严肃游戏的用户行为轨迹实时分析
• 游戏运营中的实时数据监控与反馈
• 流数据处理场景下的ElasticSearch数据写入需求

配置说明

需通过环境变量配置核心依赖服务地址：

• KAFKA_BROKERS：Kafka集群地址（如kafka:9092）
• KAFKA_TOPIC：输入数据的Kafka主题名称
• ELASTICSEARCH_HOST：ElasticSearch服务主机地址
• ELASTICSEARCH_PORT：ElasticSearch服务端口（默认9200）

Docker部署示例

Docker Run命令

bash
docker run -d \
  --name rage-realtime \
  -e KAFKA_BROKERS=kafka:9092 \
  -e KAFKA_TOPIC=game-traces \
  -e ELASTICSEARCH_HOST=es \
  -e ELASTICSEARCH_PORT=9200 \
  docker.xuanyuan.run/eucm/rage-analytics-realtime

Docker Compose示例

yaml
version: '3.8'
services:
  realtime:
    image: eucm/rage-analytics-realtime
    environment:
      KAFKA_BROKERS: kafka:9092
      KAFKA_TOPIC: game-traces
      ELASTICSEARCH_HOST: elasticsearch
      ELASTICSEARCH_PORT: 9200
    depends_on:
      - kafka
      - elasticsearch

  kafka:
    image: confluentinc/cp-kafka:7.3.0
    environment:
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:9092
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1

  elasticsearch:
    image: elasticsearch:7.17.0
    environment:
      discovery.type: single-node