Kafka connect in docker



我正在尝试建立一个运行kafka-connect并具有独立连接器(s3-sink)的Dockerized环境。

我正在使用 docker-compose 和 Kafka、zookeeper 和我的制作器都运行良好,但 kafka connect 的 docker 映像在启动后立即关闭。我使用了文档中的示例,但没有一个使用入口点或CMD。

此外,当我阻止它关闭并尝试启动我的连接器时./bin/connect-standalone它失败并显示以下错误org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches io.confluent.connect.s3.S3SinkConnector

我的 Docker 组合是两行,第一行应该做我的第一个问题,第二行是安装第二个问题声称缺少的东西......

当然,我在这里错过了一些应该如何工作的东西,任何想法吗?

我阻止了映像关闭,它仍然没有在带有 kafka 连接 REST 接口的端口 8083 上公开任何内容

FROM confluentinc/cp-kafka-connect-base:5.3.0
RUN confluent-hub install --no-prompt confluentinc/kafka-connect-s3:5.3.0
COPY . .
#CMD["connect-standalone", "connect-standalone.properties", "s3-sink.properties"]

我希望 Docker 映像不会关闭并公开端口 8083

答:其余 API 在连接器启动时启动。如果连接器失败,API 将关闭,容器也会关闭。

您需要将环境变量设置为CONNECT_PLUGIN_PATH插件安装到的任何路径。

如果您在 confluent-hub install 命令中使用 --verbose,则该插件正在安装到/usr/share/confluent-hub-components/

默认情况下,可执行文件正在其他文件夹中查找。

其余 API 在连接器启动时启动。如果连接器失败,API 将关闭,容器也会关闭。

相关内容

  • 没有找到相关文章

最新更新