Debezium，使用主键进行分区分配

Question

我是 debezium 的新手，我找不到有关使用特定键将消息从数据库发送到 kafka 的信息。是否可以将 debzium 配置为基于主键之一发送带有特殊键的消息？我可以使用 debezium 转换或一些正则表达式来实现这一点吗？

Answer 1

根据documentation page 有一个主题路由 SMT，它所做的不仅仅是更改 Kafka 记录密钥。我仍然建议要小心，因为 Kafka 分区保证了分区内的事件顺序。更改它可能会破坏 Debezium 提供的订购保证。