nebulaorchestrator/reporter

Nebula Reporter 镜像

镜像概述

Nebula Reporter是Nebula容器编排器的可选组件，负责从Kafka拉取Nebula集群的状态报告数据，并将其写入后端数据库。同时，它也支持作为通用数据接收器，处理Kafka中的JSON格式消息并持久化到MongoDB中，适用于各类分布式数据收集场景。

核心功能

1. Nebula集群状态收集：拉取来自Nebula worker节点的状态报告（通过Kafka传递），并写入后端数据库；
2. 通用数据同步：作为Kafka到MongoDB的通用数据通道，支持任意JSON格式消息的接收与存储；
3. 分布式场景适配：兼容Nebula针对大规模、高延迟网络环境（如全球分布式集群）的设计特性。

使用场景

1. Nebula集群监控：收集分布式集群中worker节点的运行状态，用于监控与分析；
2. 数据持久化：将Kafka中的JSON数据批量或实时写入MongoDB，满足数据存储需求；
3. 边缘/物联网场景：适配IoT设备、边缘计算节点等分布式环境的数据收集需求。

配置说明

需通过环境变量配置关键参数（示例）：

• KAFKA_BROKERS：Kafka集群地址（如 kafka:9092）；
• MONGODB_URI：MongoDB连接字符串（如 mongodb://mongo:27017/nebula）；
• KAFKA_TOPIC：监听的Kafka主题名称（如 nebula-reports）；
• 更多配置项请参考Nebula官方文档。

部署示例

Docker Run命令

bash
docker run -d \
  --name nebula-reporter \
  -e KAFKA_BROKERS=kafka:9092 \
  -e MONGODB_URI=mongodb://mongo:27017/nebula \
  -e KAFKA_TOPIC=nebula-reports \
  nebulaorchestrator/reporter

Docker Compose示例

yaml
version: '3'
services:
  reporter:
    image: nebulaorchestrator/reporter
    environment:
      KAFKA_BROKERS: kafka:9092
      MONGODB_URI: mongodb://mongo:27017/nebula
      KAFKA_TOPIC: nebula-reports
    depends_on:
      - kafka
      - mongo
  kafka:
    image: wurstmeister/kafka:latest
  mongo:
    image: mongo:latest