我们的团队正在开发 Kafka Connect 源连接器插件。
您对如何安装/升级插件有任何想法吗?流程(git -> Jenkins -> 运行源连接器)应该如何在本地查看?
我们在 Kubernetes 上使用 Confluent,这让事情变得更加复杂。
PS。法律要求我们不得使用云解决方案。
我们的团队正在开发 Kafka Connect 源连接器插件。
您对如何安装/升级插件有任何想法吗?流程(git -> Jenkins -> 运行源连接器)应该如何在本地查看?
我们在 Kubernetes 上使用 Confluent,这让事情变得更加复杂。
PS。法律要求我们不得使用云解决方案。
要存储自定义连接器,请使用 Nexus、Artifactory、S3 或一些普通的 HTTP/文件服务器。
如果您使用的是 Kubernetes,那么您可能有一个围绕 Docker 镜像的发布策略。
因此,您可以通过向 Dockerfile 添加附加RUN
语句来扩展 Confluent Connect Docker 映像,然后使用 Jenkins 构建和标记您的映像,并升级您的 Kubernetes 服务以使用新的映像标记。
对于管理 Kafka Connect 的裸机(或云)安装,我给出的答案是使用 Ansible 或其他编排工具来推出新文件,然后重新启动服务