docker - 用于Confluent的Docker镜像-添加Confluent Hub连接器

标签 docker apache-kafka apache-kafka-connect confluent-platform confluent-control-center

我想稍微修改一下Confluent的Git repo Dockerfile,使其在我的Confluent Connect页面mongoDB和Snowflake连接中。一切正常,但我在门户中看不到它们。
是否也应该修改docker-compose.yml
原始代码:

FROM confluentinc/cp-server-connect-base:5.5.1

ENV CONNECT_PLUGIN_PATH="/usr/share/java,/usr/share/confluent-hub-components"

ARG CONNECTOR_NAME
RUN confluent-hub install --no-prompt confluentinc/${CONNECTOR_NAME}:5.5.0
模式代码:
FROM confluentinc/cp-server-connect-base:5.5.1

ENV CONNECT_PLUGIN_PATH="/usr/share/java,/usr/share/confluent-hub-components"

ARG CONNECTOR_NAME
RUN confluent-hub install --no-prompt confluentinc/${CONNECTOR_NAME}:5.5.0 \
   && confluent-hub install --no-prompt mongodb/kafka-connect-mongodb:1.2.0 \
   && confluent-hub install --no-prompt snowflakeinc/snowflake-kafka-connector:1.4.3

最佳答案

我认为您可以尝试执行以下操作。

  • 修改您的Dockerfile:

  • FROM confluentinc/cp-server-connect-base:5.5.1
    
    ENV CONNECT_PLUGIN_PATH="/usr/share/java,/usr/share/confluent-hub-components"
    
    RUN confluent-hub install --no-prompt mongodb/kafka-connect-mongodb:1.2.0 \
       && confluent-hub install --no-prompt snowflakeinc/snowflake-kafka-connector:1.4.3
    
    由于只需要安装mongodbsnowflake连接器。
  • docker-compose.yml中使用您的自定义图像:

  • ...
      connect:
        # image: cnfldemos/cp-server-connect-datagen:0.3.2-5.5.0
        build: .
        hostname: connect
        container_name: connect
    ...
    

    关于docker - 用于Confluent的Docker镜像-添加Confluent Hub连接器,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/63964087/

    相关文章:

    java - 如何为 Java Spring Boot 和 MySql 设置 Docker 容器

    java - 使用 Java 更新 kafka 中特定主题的 TTL

    mysql - 如何配置 Debezium Mysql 连接器来生成原始键而不是 struct 或 json 对象?

    apache-kafka - 如何在 Kafka Source Connector 中编写自定义 SMT 来混淆私有(private)数据

    mysql - Confluence jdbc 连接器无法使用时间戳列进行增量查询

    node.js - 如果容器处于 CrashLoopBackOff 状态,如何执行到容器并查看文件

    linux - 我应该在 Windows 或 Docker 命令行上运行 Docker 命令吗?

    Docker 卷无法与 Docker-compose 一起生成 Doxygen 文档

    使用 Apache kafka 复制 Oracle 数据

    java - 无法捕获 Kafka TopicExistsException