Kafka Connect,插件路径

rom*_*an_ 3 apache-kafka docker apache-kafka-connect

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

      CONNECT_PLUGIN_PATH: "/usr/share/java,/usr/share/confluent-hub-components"
      volumes: -/home/madmin/connectorf:/usr/share/java
Run Code Online (Sandbox Code Playgroud)

Rob*_*att 5

您不想将本地连接器安装到现有/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
Run Code Online (Sandbox Code Playgroud)

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

另一种选择是直接将它们安装在容器中,如下所示

    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
Run Code Online (Sandbox Code Playgroud)