kpmeen/kafka-websocket-proxy

kafka-websocket-proxy 镜像文档

镜像概述

kafka-websocket-proxy 是一个WebSocket代理服务，主要用于实现通过WebSocket协议与Kafka集群进行消息交互。该镜像提供了便捷的方式，使客户端能够通过WebSocket连接消费Kafka主题消息或向Kafka主题生产消息，简化了WebSocket与Kafka之间的通信流程。

核心功能与特性

• 双向消息交互：支持从Kafka主题消费消息（Consume）和向Kafka主题生产消息（Produce）
• WebSocket协议支持：基于WebSocket协议实现客户端与代理服务的实时通信
• Kafka集成：无缝对接Kafka集群，支持标准Kafka消息交互模式

使用场景与适用范围

• 实时数据可视化应用，需通过WebSocket接收Kafka中的实时数据流
• 前端Web应用需要与Kafka集群进行消息交互的场景
• 需通过WebSocket协议提供Kafka消息接口的服务端应用
• 开发环境中快速搭建WebSocket与Kafka的桥接服务

使用方法与配置说明

官方文档与代码仓库

• 详细使用文档：[***]
• 代码仓库：[***]

基本部署示例

Docker Run 命令

bash
docker run -d \
  -p 8080:8080 \
  -e KAFKA_BOOTSTRAP_SERVERS=kafka-broker:9092 \
  --name kafka-websocket-proxy \
  kpmeen/kafka-websocket-proxy

Docker Compose 配置示例

yaml
version: '3'
services:
  kafka-websocket-proxy:
    image: kpmeen/kafka-websocket-proxy
    ports:
      - "8080:8080"
    environment:
      - KAFKA_BOOTSTRAP_SERVERS=kafka:9092
    depends_on:
      - kafka
  kafka:
    image: confluentinc/cp-kafka:latest
    environment:
      - KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://kafka:9092
      - KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1
      - KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181
    depends_on:
      - zookeeper
  zookeeper:
    image: confluentinc/cp-zookeeper:latest
    environment:
      - ZOOKEEPER_CLIENT_PORT=2181

主要配置参数

具体配置参数请参考官方文档，常用环境变量可能包括：

• KAFKA_BOOTSTRAP_SERVERS：Kafka集群引导服务器地址（必填）
• PORT：代理服务监听端口（默认8080）
• KAFKA_CONSUMER_GROUP_ID：消费者组ID（默认值可能由镜像定义）
• LOG_LEVEL：日志级别（如INFO、DEBUG等）

客户端连接说明

客户端可通过WebSocket协议连接到代理服务（默认地址 ws://localhost:8080），具体消息格式和交互方式请参考官方文档中的客户端API说明。