debezium - 了解 Debezium

Question

提供了一个用例:

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

数据库名称:myWebsite集合:用户

并且作业接收 users 集合中的 user 记录。

1. 那么 Debezium 将监视 users 集合的更改，并且在每次更改时，都会在 Kafka 中生成有关 dbserver1.myWebsite.users 主题的事件？假设 dbserver1 是连接器的名称。
2. 如果是这样，那么我可以有一个 Kafka 消费者来消费 dbserver1.myWebsite.users 主题并对这些事件使用react？
3. 据我了解，Debezium 产生的事件也包含数据库记录的值？如果它的更改包含旧/新值？如果创建了一条数据库记录，旧记录为空？

我想要某种形式来确认我到目前为止的理解。谢谢!

Answer 1

答案很简单

1. 是
2. 是的，它可以是任意的k​​afka消费者或Kafka流，或者您可以使用KSQL查询它
3. 是的，Debezium 记录不仅由旧值(之前)和新值(之后)组成。在 INSERT 的情况下，仅存在 after 在 UPDATE 的情况下，before 和 after 都存在> 存在(Postgres 需要对其进行特殊设置)，并且在 DELETE 的情况下仅存在 before。