openmf/ph-ee-importer-es Docker 镜像 - 轩辕镜像 | Docker 镜像高效稳定拉取服务

Zeebe-Kafka-Elasticsearch 桥接微服务镜像

镜像概述

该Docker镜像提供一个微服务，核心功能是消费Kafka中的消息，并将所有与Zeebe相关的数据提取、处理后发送到Elasticsearch进行存储和索引，实现Zeebe工作流数据的高效持久化与检索。

核心功能和特性

• Kafka消息消费：持续监听并消费指定Kafka主题中的Zeebe相关消息
• Zeebe数据处理：解析Zeebe工作流引擎产生的各类记录数据（如流程实例、任务、事件等）
• Elasticsearch集成：将处理后的Zeebe数据格式化并批量写入Elasticsearch
• 数据一致性：确保Kafka消息消费与Elasticsearch写入的事务一致性

使用场景和适用范围

• Zeebe工作流数据的集中化存储与管理
• 基于Elasticsearch的Zeebe流程监控与分析平台构建
• 工作流审计日志的持久化与检索需求
• 需要对Zeebe运行数据进行实时或离线分析的场景

使用方法和配置说明

环境变量配置

部署示例

Docker Run 命令

bash
docker run -d \
  --name zeebe-kafka-elasticsearch-bridge \
  -e KAFKA_BOOTSTRAP_SERVERS=kafka:9092 \
  -e KAFKA_TOPICS=zeebe-record,zeebe-incidents \
  -e ELASTICSEARCH_HOST=elasticsearch \
  -e ELASTICSEARCH_PORT=9200 \
  -e ELASTICSEARCH_USERNAME=elastic \
  -e ELASTICSEARCH_PASSWORD=changeme \
  [镜像名称]:[标签]

Docker Compose 配置

yaml
version: '3.8'

services:
  zeebe-bridge:
    image: [镜像名称]:[标签]
    container_name: zeebe-kafka-elasticsearch-bridge
    environment:
      - KAFKA_BOOTSTRAP_SERVERS=kafka:9092
      - KAFKA_TOPICS=zeebe-record,zeebe-jobs,zeebe-variables
      - ELASTICSEARCH_HOST=elasticsearch
      - ELASTICSEARCH_PORT=9200
      - ELASTICSEARCH_USERNAME=elastic
      - ELASTICSEARCH_PASSWORD=changeme
      - BATCH_SIZE=200
      - CONSUMER_GROUP_ID=zeebe-es-bridge-prod
    depends_on:
      - kafka
      - elasticsearch

  kafka:
    image: confluentinc/cp-kafka:latest
    # Kafka相关配置...

  elasticsearch:
    image: docker.elastic.co/elasticsearch/elasticsearch:8.11.0
    # Elasticsearch相关配置...