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），无需编写自定义代码即可实现数据流转。更多信息参见 ***文档。

镜像核心特性

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

使用场景与适用范围

数据集成场景：需将数据库、文件系统、消息队列等外部系统与 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 配置需通过环境变量或配置文件定义，详细参数参见 ***配置参考。核心配置项包括：

集群相关：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