小编Ale*_*lex的帖子

提供了一个用例：

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

数据库名称：myWebsite 集合：users

并且该作业会将user记录放入users集合中。

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

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

我在理解ProducerRecord.

以前我是这样构建的ProducerRecord：

new ProducerRecord<String, String>("my-topic", "key", "value")

我想另外传入一个时间戳，所以我决定检查文档并发现构造函数确实允许传递时间戳。但它也需要指定一个像这样的分区：

new ProducerRecord(String topic,
              Integer partition,
              Long timestamp,
              K key,
              V value)

我对传递什么作为分区参数感到困惑，因为我之前使用的构造函数正在为我处理它。