我们很高兴地宣布开云体育官方注册网址Debezium 0.5.0现在可用于Kafka连接0.10.2.0.此版本还包括一些修复MySQL连接器.看到发布说明有关这些更改的详细信息,请参阅卡夫卡的文档与你正在使用的Kafka代理版本的兼容性。

Kafka Connect 0.10.2.0带来了一个重要的新特性单个消息转换,现在可以将它们与Debezium连接器一起使用。开云体育官方注册网址smt允许您在将消息写入Kafka之前修改Debezium连接器和其他任何Kafka Connect开云体育官方注册网址源连接器产生的消息。smt也可以与Kafka Connect接收器连接器一起使用来修改消息之前接收器连接器处理它们。您可以使用smt过滤或屏蔽特定字段、添加新字段、修改现有字段、更改将消息写入的主题和/或主题分区,等等。你甚至可以将多个smt链接在一起。

Kafka Connect提供了许多内置的SMT,你可以简单地配置和使用,但你也可以创建自己的SMT实现来做更复杂和有趣的事情。例如,尽管Debezium连接器通常将每个表开云体育官方注册网址(或集合)中的所有更改映射到单独的主题,但您可以编写一个自定义SMT,在表和主题之间使用完全不同的映射,甚至向消息键和/或值添加字段。使用你的新SMT也很简单——简单地把它放在Kafka Connect类路径上,并更新连接器配置来使用它。

我们还添加了开云体育官方注册网址Debezium Docker图像贴上标签0.5而且最新的,我们在我们的教程

感谢Sanjay和社区中的每个人对这个发布、问题、讨论、贡献和问题的帮助!

接下来是什么

我们将继续改进MongoDB、MySQL和PostgreSQL连接器,并推出0.5。X版本带有修复。我们还在为SQL Server而且甲骨文.请继续关注并参与进来!

兰德尔Hauch

Randall是Red Hat的一名开源软件开发人员,在数据集成领域工作了近20年。他是Debezium的创始人,并参与了其他开云体育官方注册网址几个开源项目。他住在伊利诺伊州圣路易斯附近的爱德华维尔。


关于Debe开云体育官方注册网址zium

开云体育官方注册网址Debezium是一个开源的分布式平台,它将现有数据库转换为事件流,因此应用程序几乎可以立即看到并响应数据库中提交的每一个行级更改。开云体育电动老虎机开云体育官方注册网址Debezium是建立在卡夫卡并提供卡夫卡连接监控特定数据库管理系统的兼容连接器。开云体育电动老虎机开云体育官方注册网址Debezium在Kafka日志中记录了数据更改的历史,所以你的应用程序可以在任何时候停止和重新启动,并且可以很容易地使用它没有运行时错过的所有事件,确保所有事件都被正确和完整地处理。开云体育官方注册网址Debezium是开源Apache许可证,版本2.0

参与

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

Baidu
map