首页 > 解决方案 > Kafka Connect,插件路径

问题描述

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

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

标签: dockerapache-kafkaapache-kafka-connect

解决方案


您不想将本地连接器安装在现有/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

请记住,在工作程序启动之前需要存在连接器;您无法设置本地路径,然后在它开始运行后添加新路径。

另一种选择是直接将它们安装在容器中,像这样

    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

推荐阅读