cnfldemos/kafka-connect-datagen

kafka-connect-datagen Docker镜像文档

镜像概述和主要用途

本镜像旨在提供kafka-connect-datagen连接器的部署与运行环境。kafka-connect-datagen是一款用于生成测试数据的Kafka Connect连接器，可帮助用户快速构建Kafka数据流转场景。镜像源代码托管于GitHub：https://github.com/confluentinc/kafka-connect-datagen%EF%BC%8C%E8%AF%A6%E7%BB%86%E4%BD%BF%E7%94%A8%E7%A4%BA%E4%BE%8B%E5%8F%AF%E5%8F%82%E8%80%83Confluent%E5%AE%98%E6%96%B9%E7%A4%BA%E4%BE%8B%E4%BB%93%E5%BA%93%EF%BC%9Ahttps://github.com/confluentinc/examples%E3%80%82

核心功能和特性

• 版本化管理：镜像标签采用[kafka-connect-datagen版本]-[Connect版本]格式，清晰标识组件版本，例如0.1.3-5.3.0表示集成kafka-connect-datagen 0.1.3版本与Confluent Platform (CP) 5.3.0版本的Kafka Connect
• 即开即用：预装kafka-connect-datagen连接器，无需手动配置依赖，简化部署流程
• 兼容性保障：严格匹配连接器与Kafka Connect版本，确保在指定Confluent Platform环境中稳定运行

使用场景和适用范围

• 开发测试环境：快速生成结构化测试数据，验证Kafka主题、消费者及流处理逻辑的正确性
• Kafka Connect数据源：作为Kafka Connect的上游数据源，为Kafka集群提供模拟业务数据
• 学习与演示：适用于Kafka Connect功能教学、技术演示或培训场景，降低环境搭建复杂度

使用方法和配置说明

标签格式说明

镜像标签由两部分组成，格式为[kafka-connect-datagen版本]-[Connect版本]：

• [kafka-connect-datagen版本]：连接器自身版本号（如0.1.3）
• [Connect版本]：对应的Confluent Platform Kafka Connect版本号（如5.3.0，前缀"CP"为版本标识）

获取镜像

通过Docker命令拉取指定版本镜像：

bash
# 通用格式
docker pull docker.xuanyuan.run/confluentinc/kafka-connect-datagen:[标签]

# 示例：拉取kafka-connect-datagen 0.1.3 + Connect CP 5.3.0版本
docker pull docker.xuanyuan.run/confluentinc/kafka-connect-datagen:0.1.3-5.3.0

运行与配置指南

镜像的详细运行参数、连接器配置（如数据格式、生成速率、主题映射等）及完整部署示例，请参考官方示例仓库：https://github.com/confluentinc/examples%E3%80%82%E8%AF%A5%E4%BB%93%E5%BA%93%E5%8C%85%E5%90%ABKafka Connect集群部署、连接器注册及数据生成验证的端到端教程。