Debezium UI 团队很高兴宣布 Debezium UI 支持单消息转换 (SMT)!

我们的 Debezium 图形用户界面的目标是让用户更轻松地设置和操作连接器。为此,我们在 UI 中添加了对 Kafka Connect 单消息转换 的支持。请继续阅读以获取更多信息,以及新功能的视频演示!

单消息转换 (SMT)

连接器可以通过转换进行配置,以实现轻量级的每条消息修改。 常见的 SMT 用例 包括格式转换(例如,不同的日期格式和数字类型)、消息过滤和路由、处理“墓碑”事件、加密/解密等。

Debezium 提供了一些单消息转换 (SMT),您可以在将记录发送到 Apache Kafka 之前(通过将其应用于 Debezium 连接器)或当接收器连接器从 Kafka 读取记录时使用它们。例如,我们提供的 SMT 可以仅提取更改事件中的“after”部分,并以扁平的行格式传播,以及用于路由来自 outbox 表的事件的 SMT。

要了解有关 Debezium 附带的 SMT 的更多信息,请参阅 参考文档。得益于 Debezium UI 对 SMT 的支持,配置它们比以往任何时候都更容易;有关此功能实际应用的简短演示,请参见以下视频:

有趣的事实:此视频是我们全新的 Debezium YouTube 频道 的第一个条目!我们建议您订阅该频道,以免错过任何新视频。

自己尝试

我们在 GitHub 上创建了一个名为 UI 演示 的独立示例,它包含在 debezium-examples 中。UI 演示包含一个 Docker Compose 文件,该文件可以启动多个数据源以及 UI。有关运行 Debezium UI 演示的更多详细信息,请参阅 README 文件

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

后续步骤

我们计划在未来的版本中继续改进 UI 并添加新功能。一些正在考虑的项目:

  • 集成更多 Debezium 连接器类型,例如 SQL Server 和 Oracle 的连接器

  • 添加和改进连接器指标和监控

  • 添加创建后查看和编辑连接器属性的功能

  • ……以及更多!

我们也非常乐意了解您对 Debezium UI 的需求和反馈。请在下面的评论中告诉我们,或者发送消息到我们的 邮件列表

非常感谢为团队做出各种贡献的成员:Ashique Ansari、Indra Shukla、René Kerner 和 Gunnar Morling!

Mark Drilling

Mark 是 Red Hat 的一名软件开发人员。他在 Red Hat 工作的大部分时间都致力于各种数据虚拟化项目,现在他从事 Debezium 的工作。他居住在美国密苏里州 O'Fallon。

 


关于 Debezium

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

参与进来

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

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