Debezium 中初始快照事件的顺序

Question

在我们的应用程序中，我们需要将某个 postgresql 表中的事件发布到 Kafka 中，因此我们决定使用 Debezium，但遇到了以下问题：在初始快照期间，消息以意外的（从我们的角度来看）顺序显示在 Kafka 中。事件的顺序对于我们的应用程序至关重要，实际上它们必须按表的整数主键排序。AFAIK 初始快照只是表中的 SELECT，没有 ORDER BY。那么有没有一种方法或解决方法可以使Debezuim postgresql 连接器按特定顺序提取事件？

提前致谢！

Answer 1

查看连接器文档snapshot.select.statement.overrides中的属性。它允许您自定义用于特定表的 SELECT 语句，因此您可以附加所需的 ORDER BY 子句。