confluentinc/cp-kafka-connect

Confluent Kafka Connect Docker 镜像文档

概述

Confluent Kafka Connect Docker 镜像是用于部署和运行 Kafka Connect 的官方容器镜像。

注意：cp-kafka-connect 与 cp-kafka-connect-base 镜像功能完全一致。在 Confluent Platform 6.0 之前，cp-kafka-connect 镜像预装了多个连接器，目前该特性已移除，两者无差异。

核心功能与特性

关于 Kafka Connect

Kafka Connect 是 Apache Kafka 的组件，用于将外部系统与 Kafka 集群集成，支持数据导入（Source Connector）和导出（Sink Connector），无需编写自定义代码即可实现数据流转。更多信息参见 https://docs.confluent.io/platform/current/connect/index.html#what-is-kafka-connect%E3%80%82

镜像核心特性

• 轻量级容器化部署，简化 Kafka Connect 服务搭建流程。
• 支持插件化架构，可集成连接器（Connectors）、转换器（Converters）、转换（Transforms）等扩展组件。
• 兼容 https://hub.confluent.io 上的数百种第三方连接器。

使用场景与适用范围

• 数据集成场景：需将数据库、文件系统、消息队列等外部系统与 Kafka 集群对接时使用。
• ETL/数据流处理：作为数据管道的核心组件，实现上游数据源到 Kafka 或 Kafka 到下游系统的数据流转。
• 开发与生产环境：支持本地开发调试和大规模生产部署，灵活适配不同场景需求。

使用方法与配置说明

安装连接器

Kafka Connect 依赖插件（如连接器 JAR 包）实现功能扩展，需手动安装插件至镜像。以下是三种常用安装方式：

1. 扩展基础镜像

通过 Dockerfile 基于基础镜像构建新镜像，将连接器 JAR 包直接打包进镜像。
示例：

dockerfile
FROM confluentinc/cp-kafka-connect:latest
RUN confluent-hub install --no-prompt confluentinc/kafka-connect-jdbc:latest

2. 挂载外部卷

通过挂载宿主机目录的方式，将连接器 JAR 包映射到容器内的插件目录（默认插件路径：/usr/share/java/）。
示例（docker-compose 配置片段）：

yaml
volumes:
  - ./connectors/jdbc:/usr/share/java/kafka-connect-jdbc
  - ./connectors/elasticsearch:/usr/share/java/kafka-connect-elasticsearch

3. 运行时安装

在容器启动时通过命令行安装连接器（需确保容器内网络可访问 Confluent Hub）。
示例（docker-compose 配置片段）：

yaml
environment:
  - CONNECT_PLUGIN_PATH=/usr/share/java,/usr/share/confluent-hub-components
command: 
  - bash 
  - -c 
  - |
    confluent-hub install --no-prompt confluentinc/kafka-connect-jdbc:latest
    confluent-hub install --no-prompt confluentinc/kafka-connect-elasticsearch:latest
    /etc/confluent/docker/run

配置参考

Kafka Connect 配置需通过环境变量或配置文件定义，详细参数参见 https://docs.confluent.io/platform/current/installation/docker/config-reference.html#kconnect-long-configuration%E3%80%82%E6%A0%B8%E5%BF%83%E9%85%8D%E7%BD%AE%E9%A1%B9%E5%8C%85%E6%8B%AC%EF%BC%9A

• 集群相关：bootstrap.servers（Kafka 集群地址）、group.id（Connect 集群组 ID）。
• 连接器配置：key.converter/value.converter（键/值转换器，如 org.apache.kafka.connect.json.JsonConverter）、offset.storage.topic（偏移量存储主题）等。

Docker 部署示例

docker-compose 配置示例（挂载连接器 JAR）

yaml
version: '3'
services:
  kafka-connect:
    image: confluentinc/cp-kafka-connect:latest
    depends_on:
      - kafka
    environment:
      - BOOTSTRAP_SERVERS=kafka:9092
      - GROUP_ID=connect-cluster
      - KEY_CONVERTER=org.apache.kafka.connect.json.JsonConverter
      - VALUE_CONVERTER=org.apache.kafka.connect.json.JsonConverter
      - OFFSET_STORAGE_TOPIC=connect-offsets
    volumes:
      # 挂载宿主机连接器 JAR 目录至容器插件路径
      - ./local-connectors:/usr/share/java/kafka-connect-custom

docker-compose 配置示例（运行时安装连接器）

yaml
version: '3'
services:
  kafka-connect:
    image: confluentinc/cp-kafka-connect:latest
    depends_on:
      - kafka
    environment:
      - BOOTSTRAP_SERVERS=kafka:9092
      - GROUP_ID=connect-cluster
      - CONNECT_PLUGIN_PATH=/usr/share/java,/usr/share/confluent-hub-components
    command:
      - bash
      - -c
      - |
        # 安装 PostgreSQL 连接器
        confluent-hub install --no-prompt confluentinc/kafka-connect-jdbc:latest
        # 启动 Kafka Connect
        /etc/confluent/docker/run

贡献

参与方式

1. 阅读项目贡献指南（详见源码仓库文档）。
2. 源码仓库：https://github.com/confluentinc/kafka-images
3. 问题跟踪：https://github.com/confluentinc/kafka-images/issues

许可证

使用本镜像需遵守镜像包含软件的许可条款。详见 https://docs.confluent.io/platform/current/installation/docker/image-reference.html%E3%80%82%E6%89%A9%E5%B1%95%E5%92%8C%E6%9E%84%E5%BB%BA%E8%87%AA%E5%AE%9A%E4%B9%89%E9%95%9C%E5%83%8F%E7%9A%84%E8%BD%AF%E4%BB%B6%E5%9F%BA%E4%BA%8E Apache 2.0 许可证开源。