理解Debezium

Question

提供用例：

流处理体系结构；事件进入Kafka，然后由带有MongoDB接收器的作业处理。

数据库名称：myWebsite集合：users

作业在user集合中接收users记录。

1. 因此，Debezium将监视users集合中的更改，并且在每次更改时，都会生成主题为dbserver1.myWebsite.users的卡夫卡事件？假设dbserver1是连接器的名称。
2. 如果是这样的话，那么我可以有一个卡夫卡消费者从dbserver1.myWebsite.users主题消费，并对这些事件作出反应？
3. 据我所知，Debezium产生的事件也包含数据库记录的值？如果更改包含旧/新值？如果创建了db记录，则旧记录为null？

到目前为止，我希望得到某种程度的确认。谢谢!

Answer 1

答案很简单

1. 是
2. 是的，它可以是任意的kafka使用者或Kafka流，也可以使用KSQL查询。
3. 是的，Debezium记录不仅由旧值(before)和新值(after)组成。在INSERT的情况下，只有after出现在UPDATE的情况下，before和after都存在(Postgres需要一个特殊的设置)，在DELETE的情况下，只有before是存在的。