使用带有 Helm 安装的 Kafka/Confluence 的连接器

2024-01-12

我已经使用 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 命令。

问题:

  1. confluence-hub 不是通过 Helm 图表安装的吗?
  2. 我必须自己安装 confluence-hub 吗?
  3. 如果是这样,我必须将其安装在哪个 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(使用前将#替换为@)

使用带有 Helm 安装的 Kafka/Confluence 的连接器 的相关文章

  • 无法在 Mac 上启动 MySQL

    使用 Brew 安装后 我无法运行 MySQL 我使用的是 OS X El Capitan 版本 10 11 3 和 MySQL Server 版本 5 7 11 当我启动服务器时 我收到 启动 MySQL 错误 服务器退出而不更新 PID
  • 如何在 MySQL 中测试 Select for Update

    我正在表演SELECT FOR UPDATE或 InnoDB 表的行级锁定 我的目的是只有一个请求可以读取同一行 因此 如果两个用户同时请求相同的数据 其中只有一个人获取数据 即第一个触发查询的人 但是我如何测试锁定是否已放置 因为我正在通
  • mysql 中的二进制、十六进制和八进制值

    我对在 mysql 数据库中使用二进制 十六进制和八进制系统非常感兴趣 首先 请给我一个建议 为什么我们在存储信息时需要它们 因为信息太多 或者为什么 另外 哪种类型的值必须存储在标记系统中 另外这里还有像 这是例子 gt SELECT 5
  • 用 pandas DataFrame 替换 mysql 数据库表中的行

    Python 版本 2 7 6 熊猫版本 0 17 1 MySQLdb 版本 1 2 5 在我的数据库中 PRODUCT 我有一张桌子 XML FEED 表 XML FEED 很大 数百万条记录 我有一个 pandas DataFrame
  • 在 SQL 中,如何从 SELECT * FROM ... 中排除结果?

    我知道我的标题不太具有描述性 让我在这里详细解释一下 假设一个表有 26 个字段 例如字段 a 字段 z 我只想要一个选择查询只返回 15 个字段 所以 通常 我会执行 SELECT field a field b field o FROM
  • 将庞大数据库从亚马逊RDS导出到本地mysql

    我在 Amazon RDS 上有一个 mysql 数据库 大约 600GB 数据 我需要将其移回本地专用服务器 但我不知道从哪里开始 每次我尝试初始化 sqldump 时它都会冻结 有没有办法将其移至 S3 甚至可能在开始下载之前将其分成更
  • MySQL/PDO::quote() 尽管使用 PDO::PARAM_INT 参数,但仍在整数周围加上引号

    无论我传递给什么值 数据类型对 它都会出现 pdo gt quote value type 它总是将其引用为字符串 echo pdo gt quote foo PDO PARAM STR foo as expected echo pdo g
  • Mysql用in语句限制

    我正在写一个查询 SELECT user bookmarks id as user bookmark id bookmark id user bookmarks user id bookmark url bookmark website b
  • PHP 与 MySQL 查询性能( if 、 函数 )

    我只看到这个artice http www onextrapixel com 2010 06 23 mysql has functions part 5 php vs mysql performance 我需要知道在这种情况下什么是最好的表
  • 在 android 中建立与 MySQL 的池连接

    我需要从我的 Android 应用程序访问 MySQL 数据库 现在所有的工作都通过 DriverManager getConnection url 等等 但我必须从多个线程访问数据库 所以我必须使用连接池 问题1 是 com mysql
  • SQL 最近日期

    我需要在 php 中获取诸如 2010 04 27 之类的日期作为字符串 并在表中找到最近的 5 个日期 表中的日期保存为日期类型 您可以使用DATEDIFF http dev mysql com doc refman 5 1 en dat
  • SELECT NULL、*、NULL、NULL 中令人困惑的 SQL 错误

    的背景我试图解决第四个现实任务 https www hackthissite org playlevel 4 在 hackthissite org 中 无法确切地弄清楚我应该在 URL 中注入什么 SQL 来检索电子邮件列表 浪费了几个小时
  • kubernetes:无法从其他机器访问 NodePort

    我正在尝试安装 kubernetes 检查kubernetes上执行的容器时出现问题 我将服务类型设置为 Nodeport 但无法从运行容器的节点以外的节点进行访问 想要从其他计算机访问它 请告诉我哪里不同 我尝试了externalIPs和
  • SQL:在行中保留计数或从数据库中选择计数

    示例 我有 2 张桌子 类别 Posts 在这样的类别中保留帖子编号是一个好方法吗 类别 id title posts 1 golf 50 2 soccer 90 posts id title category id 1 news 1 1
  • 从前端更改记录顺序

    我在编写下一个功能时遇到问题 我希望用户能够重新排列记录并更改 display order 值 我使用 Jquery UI 的可拖放功能来促进这一点 我可以看到如何简单地交换 display order 值 但我想为一条记录设置一个显示顺序
  • 如何获取日期时间字段的 UTC?

    我正在使用 MySQL 5 并且正在尝试将日期时间字段转换为 UTC TIMESTAMP 这是我所拥有的 但它不起作用 并且不确定我是否可以做到这一点 但有人可以告诉我我做错了什么吗 谢谢 我已经尝试过这个 SELECT UTC TIMES
  • 查询和扫描多行性能缓慢

    下面的查询一行的执行时间为 6 18 分钟 Exception type 1 的基数值为 3 我不知道如何提高性能 Query select count 1 as rage tap from summary funnel 1066 s jo
  • 如何从表中选择所有偶数 id?

    我想从 MySQL 数据库的表中选择所有甚至帖子 ID 然后显示它们 我还想获取所有带有奇怪 id 的帖子并将它们显示在其他地方 我想使用 PHP 来完成此操作 因为这是我使用的服务器端语言 或者 我是否必须选择所有帖子 然后使用 Java
  • Tomcat JDBC 池中没有足够的空闲连接

    给定以下 Tomcat JDBC 连接设置
  • Mysql:将数据库从本地时间转换为UTC

    我需要从本地时间 ut UTC 转换现有的 日期时间字段 数据库 这些值和日期时间存储在时区为 CET 1 夏令时 2 的服务器上 选择我使用的数据时UNIX TIMESTAMP 它神奇地补偿了一切 即时区偏移和夏令时 如果我正确阅读了文档

随机推荐

  • 表排序日期不正确

    预期的 我将从返回的 API 中获取日期时间字符串 这个值 2019 08 15T15 58 14 597Z 应在表格中显示为 DD MM YYYY HH MM Vuetify 附带一个数据表组件 可以对数据进行升序和降序排序 我还想对日期
  • 我应该为每个工作站生成新的 SSH 密钥对还是重复使用单个密钥对?

    这是来自 Windows 人员的新手问题 但是当我使用 Git 或其他依赖于 开放 SSH 的软件时 我应该为每个工作站生成一个新的 SSH 密钥 然后将公钥上传到 GitHub BitBucket 等 还是应该是否要重用之前生成的一些内容
  • Curl 可以工作,但 python requests 不行

    当我做curl时 我得到一个回应 root 3d7044bac92f home app tmp curl H Content type application json X GET https github com timeline jso
  • 如何生成多种格式的 R 包插图?

    I use knitr and 降价为 R 包编写小插图 感谢神奇的pandoc将这些文档转换成各种格式很容易 我想利用这一点 提供 HTML 和 PDF 格式的小插图 有来自的支持降价在文档元数据块中指定多种输出格式的参数 例如 我可能有
  • 为什么 if 以 string.length() 为条件的计算结果不一致?

    int main std string string hi std cout lt lt Enter index int index std cin gt gt index if index lt string length std cou
  • TensorFlow 中的动态 RNN 是什么?

    我对动态 RNN 感到困惑 即dynamic rnn 是 它返回一个output and a state在 TensorFlow 中 这些状态和输出是什么 TensorFlow 中动态 RNN 中的动态是什么 动态 RNN 允许可变序列长度
  • 为什么我安装了 mtl-2.2.2 后无法导入 Control.Monad.Writer?

    我正在尝试导入 Writer monad 其定义在mtl 2 2 2我检查后已安装的软件包ghc pkg list 当我尝试做的时候import Control Monad Writer in ghci它给了我一个错误 我不明白为什么 Pr
  • VS 2017中使用脚手架出错

    我正在尝试在 Visual Studio 2017 的 ASP NET Core 应用程序中使用 Scaffold 功能 我正在使用带有视图的 MVC 控制器和实体框架 我已经设置了 dbcontext 和迁移 并使用 update dat
  • 杰克逊列表反序列化。嵌套列表

    我正在努力创建一个具有嵌套列表的 API Jackson 似乎是一个创建对象的好工具 但我不太清楚如何嵌套列表 我想知道它是否可能 我的对象看起来像这样 public class Order public String name publi
  • 如何在 Django 用户名正则表达式中允许空格?

    我试图允许默认 django contrib auth models 用户的用户名字段接受空格 其他人之前已经直接问过或类似的问题 Here https stackoverflow com questions 19911087 how ca
  • 如何在Ant中使用javac排除源包?

    我查看了一堆不同的示例 并尝试了几种变体 但似乎无法使其正常工作 看来您无法使用 javac 排除整个目录 而只能排除文件 我想这意味着您无法指定包 这是我所拥有的
  • 在sql server中创建视图

    我试图创建链接 2 个表管理员和新闻的视图 create view v news as SELECT n id n title n detail n date n sdate n edate n admin a name a email a
  • kernel32.dll Sleep 和 Thread.Sleep() 之间有什么区别

    以下内容之间是否有任何区别 性能 实现等 i DllImport kernel32 dll public extern static void Sleep uint msec 然后调用睡眠函数 ii Thread Sleep 实际上有很大的
  • Nginx 中不同 IP 上的不同域?

    例如 我想使用具有不同 IP 地址的两个不同域 domain1 com 12 34 56 78 domain2 com 98 76 54 32 我在用nginx在 Linux 操作系统上 我应该在 nginx conf 中添加什么 你必须创
  • 使3个数组相互对应,第一个是对象名称

    我目前有多个对象 如下所示 let object1 xyz xyz1 arr object2 xyz xyz2 arr object3 xyz xyz3 arr 这变得很长而且多余 无论如何我可以创建 3 个数组 例如 let objNam
  • 向 307 重定向添加标头

    除了 Location 之外 是否真的不能添加 修改 307 标头 我正在尝试在 Node js 中执行此操作 并且客户端似乎未使用新添加的标头 X Atlassian Token no check res writeHead 307 Lo
  • 自定义 Google Map API V3 缩放按钮

    如何将 google 地图 api v3 javascript 缩放按钮自定义为我自己的图像 我在聚会上迟到了 但这是我的两分钱 您基本上有两个选择 选项1 您可以自己使用 HTML CSS 创建控件 然后可以使用绝对位置或类似方法将其放置
  • 尝试标记 odata 时,可查询属性未在 mvc 4 Web api 中编译

    我正在使用 Visual Studio 2012 附带的 MVC 4 Web api 据我了解 odata 不会自动解析 但我们现在需要向操作添加 Queryable 属性 所以我添加了它 public class TestControll
  • 如何在jinja2模板中使用变量传递过滤器名称

    我定义了一些过滤器并且经常使用它们 我需要做一些 A B 测试 为此在某些情况下一些过滤器应该以不同的方式工作 最简单的方法是在模板中创建一个存储过滤器名称的变量 像这样的东西 set filter name some name my va
  • 使用带有 Helm 安装的 Kafka/Confluence 的连接器

    我已经使用 Helm 图表在本地 Minikube 上安装了 Kafkahttps github com confluenceinc cp helm charts https github com confluentinc cp helm