kong/kong-event-gateway

KEG (Kong Event Gateway) 镜像文档

镜像概述

KEG（Kong Event Gateway）是一款基于Kong网关技术构建的事件网关镜像，专为事件驱动架构设计。它扩展了Kong的核心能力，专注于事件流的接收、路由、处理与分发，支持多种事件协议和后端服务集成，为微服务架构中的事件通信提供可靠、高效的基础设施。

核心功能与特性

事件处理能力

• 多协议支持：兼容HTTP、Kafka、NATS、RabbitMQ等主流事件传输协议，灵活对接不同事件源与消费者
• 动态事件路由：基于事件属性（如类型、来源、内容）配置路由规则，支持条件路由、扇出路由等模式
• 事件转换与过滤：内置事件格式转换（JSON、Protobuf等）和内容过滤功能，按需处理事件数据

可靠性保障

• 事件持久化：支持事件持久化存储，防止服务中断导致的事件丢失
• 智能重试机制：配置失败事件自动重试策略，支持指数退避等重试算法
• 死信队列：无法处理的事件自动路由至死信队列，便于问题排查与数据恢复

Kong生态集成

• 与Kong API网关无缝协同：共享配置管理、认证授权机制，统一管控API与事件流量
• 支持Kong插件生态：可集成Kong社区插件，扩展事件处理能力（如监控、日志、限流）

使用场景

微服务间事件通信

作为微服务架构中的事件枢纽，实现服务间松耦合的异步通信，降低服务依赖复杂度。

实时数据流处理

对接Kafka、MQTT等消息系统，实时接收并路由数据流至处理服务（如流计算、实时分析引擎）。

事件驱动架构部署

为事件驱动应用提供标准化的事件接入、处理与分发能力，简化架构设计与运维成本。

使用方法

基本部署

通过docker run快速启动KEG容器：

bash
docker run -d \
  --name keg \
  -p 8000:8000 \  # 事件接收端口
  -p 8001:8001 \  # 管理API端口
  -e KONG_ADMIN_LISTEN=0.0.0.0:8001 \
  -e KEG_EVENT_SOURCES="kafka:9092,http:8080" \  # 配置事件源（Kafka集群、HTTP端点等）
  kong/keg:latest

环境变量配置

KEG支持通过环境变量配置核心参数，常用配置如下：

路由规则配置

通过挂载路由规则配置文件（如routes.yaml）定义事件路由策略，示例：

yaml
# routes.yaml
routes:
  - name: "order-events-to-processing"
    match:
      event_type: "order.created"  # 匹配事件类型为"order.created"的事件
    destinations:
      - type: "kafka"
        address: "kafka:9092"
        topic: "order-processing"  # 路由至Kafka主题"order-processing"
  - name: "payment-events-to-audit"
    match:
      event_source: "payment-service"  # 匹配来源为"payment-service"的事件
    destinations:
      - type: "http"
        address: "http://audit-service:3000/events"  # 路由至HTTP服务

挂载配置文件启动容器：

bash
docker run -d \
  --name keg \
  -p 8000:8000 -p 8001:8001 \
  -v $(pwd)/routes.yaml:/etc/keg/routes.yaml \  # 挂载本地路由配置文件
  -e KEG_ROUTE_CONFIG=/etc/keg/routes.yaml \
  kong/keg:latest

注意事项

• 生产环境建议启用事件持久化（KEG_PERSISTENCE_ENABLE=true）并配置外部存储（如PostgreSQL）
• 路由规则变更后需重启容器或通过Kong Admin API动态更新
• 高并发场景下建议配置资源限制（--memory、--cpus）及健康检查机制