【问题标题】:Kafka Connect, plugin pathKafka Connect,插件路径
【发布时间】:2021-06-26 12:14:25
【问题描述】:

如何正确覆盖 PLUGIN_PATH 以便在启动 docker 后添加外部连接器? /home/madmin/connectorf - 带有 jar 的 PC 上的路径 - 连接器 CONNECT_PLUGIN_PATH - confluent 的默认变量 感谢您的回答。

      CONNECT_PLUGIN_PATH: "/usr/share/java,/usr/share/confluent-hub-components"
      volumes: -/home/madmin/connectorf:/usr/share/java

【问题讨论】:

    标签: docker apache-kafka apache-kafka-connect


    【解决方案1】:

    您不想将本地连接器安装在现有的 /usr/share/java 文件夹上。试试这个:

        CONNECT_PLUGIN_PATH: "/usr/share/java,/usr/share/confluent-hub-components,/usr/share/local-connectors" 
    volumes: -/home/madmin/connectorf:/usr/share/local-connectors
    

    请记住,连接器需要在 worker 启动之前存在;您不能设置本地路径,然后在它开始运行后添加新路径。

    另一种选择是直接将它们安装在容器中,like this

        command: 
          - bash 
          - -c 
          - |
            confluent-hub install --no-prompt confluentinc/kafka-connect-elasticsearch:11.0.0
            #
            echo "Launching Kafka Connect worker"
            /etc/confluent/docker/run & 
            #
            sleep infinity
    

    【讨论】:

    • 也许我有另一个版本的图像。我在 docker /usr/share/local-connectors 上没有找到这个文件夹
    • 这就是重点; /usr/share 存在,volume 命令将本地文件夹挂载到/usr/share/local-connectors
    • 如果这回答了您的问题,那么请确保将其标记为这样,以便其他人可以更轻松地找到它:)
    猜你喜欢
    • 1970-01-01
    • 2018-11-07
    • 2022-01-23
    • 2021-05-27
    • 2022-06-21
    • 2022-01-15
    • 2021-12-26
    • 2017-12-31
    • 2021-02-24
    相关资源
    最近更新 更多