Debezium UI 团队继续添加对更多功能的支持,使用户能够更轻松地配置连接器。在本文中,我们将描述并演示如何提供 UI 默认未公开的附加配置属性。请继续阅读以获取更多信息!

自定义属性步骤的需求

Debezium 非常灵活——每个连接器都可以通过多种方式进行配置和微调。Debezium UI 已经暴露了大量的属性,这些属性被分门别类地列在不同的配置步骤中。然而,尽管 UI 暴露了广泛的属性,但在某些情况下,可能需要一些 UI 开箱即用之外的附加自定义属性。例如,producer.consumer.,甚至 driver.* 属性分别是用于配置 Kafka Connect 管道的某些部分或 JDBC 驱动程序的透传配置选项。

示例

对于那些使用 Schema History Topic 的连接器(例如 MySQL),Debezium 必须配置 Kafka Producer 设置,以便将 Schema 变更事件写入 Schema History Topic。连接器配置包含一部分选项,它们作为透传属性,以 schema.history.internal.producer.* 前缀开头。

Debezium 在将属性传递给 Kafka 客户端之前,会剥离属性名称中的前缀。

自定义属性步骤

Debezium UI 允许您为 UI 中未暴露的连接器配置附加属性。为此,我们在配置向导中创建了一个新的附加步骤,称为 **自定义属性**。

**自定义属性** 步骤允许您通过输入键值对来提供附加属性。输入附加配置属性的 后,点击 **应用** 按钮。

点击 **应用** 按钮时,UI 会验证用户输入,并在出现任何问题时提供反馈。如果没有问题,UI 将在所有成功添加的附加属性的右侧显示一个绿色的勾形图标。您也可以通过点击属性右侧的 **移除** 按钮来移除已添加的属性。

在左侧,您可以看到来自前一个向导步骤的已配置属性列表,而在此步骤中新增的自定义属性将以 **蓝色** 突出显示。

在上图截屏中,用户添加了与 schema.history.internal.producer.* 相关的附加属性。

自包含示例

您可以通过我们的自包含示例 UI 演示 来尝试使用一些自定义属性(及更多)配置连接器——该示例包含在 GitHub 的 debezium-examples 中。UI 演示包含一个 Docker Compose 文件,该文件会启动多个带有数据的源和 UI。有关运行 Debezium UI 演示的更多详细信息,请参阅 README 文件

要了解更多关于 Debezium UI 的信息,请参阅 参考文档

更多内容即将推出!

敬请关注未来版本中 UI 的进一步改进和新功能公告。

非常感谢团队的贡献:Anisha Mohanty、René Kerner 和 Chrish Cranford!

Indra Raj Shukla

Indra 是 Red Hat 的一名高级软件开发工程师。他在 UI 开发方面拥有丰富的经验。他居住在印度班加罗尔。

   


关于 Debezium

Debezium 是一个开源的分布式平台,可以将现有数据库转变为事件流,使应用程序能够几乎即时地看到并响应数据库中已提交的每个行级更改。Debezium 构建在 Kafka 之上,并提供了 Kafka Connect 兼容的连接器,用于监控特定的数据库管理系统。Debezium 将数据更改的历史记录在 Kafka 日志中,这样您的应用程序可以随时停止和重新启动,并可以轻松地消费在未运行时错过的所有事件,确保所有事件都被正确且完整地处理。Debezium 在 Apache 许可证 2.0 下是 开源 的。

参与进来

我们希望您觉得 Debezium 有趣且有用,并希望尝试一下。在 Twitter @debezium 上关注我们,在 Zulip 上与我们聊天,或加入我们的 邮件列表 与社区交流。所有代码都在 GitHub 上开源,因此请在本地构建代码,帮助我们改进现有连接器并添加更多连接器。如果您发现问题或有改进 Debezium 的想法,请告诉我们或 记录一个问题

版权所有 © Debezium 及其作者。保留所有权利。有关我们的商标详情,请访问我们的 商标政策商标列表。第三方商标属于其各自所有者,在此提及并不表示任何认可或关联。
×