Debezium 博客

偶尔在 Debezium 的 聊天 或 邮件列表 中会有关于如何确保 Debezium 生成的记录的恰好一次传递的问题。到目前为止，Debezium 仅支持至少一次传递。这意味着 Debezium 保证每个更改事件都会被传递，不会丢失或跳过。但是，在发生故障、重启或数据库连接中断的情况下，同一个事件可能会被传递多次。典型的情况是事件被传递两次——一次在故障/重启之前，另一次在之后。恰好一次传递（或语义）提供了更强的保证——每个消息都会被传递，并且同时不会有任何重复，每个消息都只会被传递一次。到目前为止，我们的回答是，如果用户需要恰好一次传递，他们必须实现自己的去重系统。然而，随着 Kafka Connect 对恰好一次传递的支持，似乎我们只需稍作配置更改，就可以为 Debezium 连接器提供开箱即用的恰好一次传递。