authorjapps/wordcounter

authorjapps/wordcounter 镜像说明

镜像概述

authorjapps/wordcounter是一个轻量级Docker镜像，专注于对Kafka消息中的文本内容进行单词计数处理，适用于需要量化分析Kafka流数据文本的场景。

核心功能

• 实时监听指定Kafka主题的消息
• 准确统计消息文本中的单词数量
• 支持自定义Kafka连接参数（brokers地址、消费者组ID等）

使用场景

• 日志分析：统计应用日志消息中的关键词出现频率
• 数据监控：实时跟踪Kafka主题消息的文本长度或单词数量变化
• 业务分析：对用户生成内容（如评论、反馈）进行文本量化处理

配置说明

通过环境变量配置关键参数：

• KAFKA_BROKERS：Kafka集群地址（必填，格式：host1:port1,host2:port2）
• KAFKA_TOPIC：目标Kafka主题名称（必填）
• KAFKA_CONSUMER_GROUP：消费者组ID（可选，默认：wordcounter-default-group）

部署示例

Docker Run 快速启动

bash
docker run \
  -e KAFKA_BROKERS=192.168.1.100:9092 \
  -e KAFKA_TOPIC=user-comments \
  -e KAFKA_CONSUMER_GROUP=comment-analysis-group \
  docker.xuanyuan.run/authorjapps/wordcounter

Docker Compose 完整部署

yaml
version: "3.8"
services:
  wordcounter:
    image: authorjapps/wordcounter
    environment:
      - KAFKA_BROKERS=kafka:9092
      - KAFKA_TOPIC=product-reviews
      - KAFKA_CONSUMER_GROUP=review-wordcount-group
    depends_on:
      - kafka
  
  kafka:
    image: wurstmeister/kafka:2.13-2.8.1
    ports:
      - "9092:9092"
    environment:
      - KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://kafka:9092
      - KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181
    depends_on:
      - zookeeper
  
  zookeeper:
    image: wurstmeister/zookeeper:3.4.6
    ports:
      - "2181:2181"