我已经使用 Helm 图表在本地 Minikube 上安装了 Kafkahttps://github.com/confluenceinc/cp-helm-charts https://github.com/confluentinc/cp-helm-charts遵循这些说明https://docs.confluence.io/current/installation/installing_cp/cp-helm-charts/docs/index.html https://docs.confluent.io/current/installation/installing_cp/cp-helm-charts/docs/index.html像这样:
helm install -f kafka_config.yaml confluentinc/cp-helm-charts --name kafka-home-delivery --namespace cust360
kafka_config.yaml 几乎与默认 yaml 相同,唯一的例外是我将其缩小到 1 个服务器/代理而不是 3 个(只是因为我试图节省本地 minikube 上的资源;希望这与我的问题)。
Minikube 上还运行一个 MySQL 实例。这是输出kubectl get pods --namespace myNamespace
:
我想使用连接器之一连接 MySQL 和 Kafka(例如Debezium MySQL CDC https://www.confluent.io/connector/debezium-mysql-cdc-connector/, 例如)。在说明中,它说:
安装连接器
使用 Confluence Hub 客户端来安装它
连接器具有:
confluent-hub install debezium/debezium-connector-mysql:0.9.2
听起来不错,除了 1)我不知道在哪个 Pod 上运行此命令,2)所有 Pod 似乎都没有可用的 confluence-hub 命令。
问题:
- confluence-hub 不是通过 Helm 图表安装的吗?
- 我必须自己安装 confluence-hub 吗?
- 如果是这样,我必须将其安装在哪个 Pod 上?
理想情况下,这应该可以配置为helm
脚本,但不幸的是现在还没有。解决这个问题的一种方法是从 Confluence 的 Kafka Connect Docker 镜像构建一个新的 Docker。手动下载连接器并将内容提取到文件夹中。将其内容复制到容器中的路径。像下面这样的东西。
Dockerfile 的内容
FROM confluentinc/cp-kafka-connect:5.2.1
COPY <connector-directory> /usr/share/java
/usr/share/java
是 Kafka Connect 查找插件的默认位置。您还可以使用不同的位置并提供新位置(plugin.path
)在你的helm
安装。
构建此映像并将其托管在可访问的位置。您还必须在期间提供/覆盖图像和标签详细信息helm
安装。
Here https://github.com/confluentinc/cp-helm-charts/blob/e17565cd5a6985a594155b12b08068cb5882e51f/charts/cp-kafka-connect/values.yaml是到的路径values.yaml
文件。您可以找到image
and plugin.path
值在这里。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)