postgresql - Debezium 中初始快照事件的顺序

Question

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

提前致谢!

Answer 1

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