Kafka Connect确保订购

Question

我想使用Mongo变更流，使用kafka Connect将变更事件从mongoDB推送到kafka Topic中。好消息是：

>

Kafka在分区内维持排序。

Mongo使用全局时钟维护排序。

但是，中间呢？kafka connect怎么样？它维持订购吗？这种订购是如何运作的？我找不到他们说Kafka维持秩序的地方。

这是一个场景：

• 在Mongo中-更新用户Bob以获得授权
• 在Mongo中-将用户bob角色更新为未经授权

然后，假设我有网络延迟，并且我的kafka connect是kafka connection-Mongo Source（多个实例）的集群，那么这种情况会发生吗（排序问题）：

>

已获取将bob更新为未授权的事件

有活动更新鲍勃到授权

或者，如果Mongo更改流与kafka连接同步（以某种方式），并且上述情况永远不会发生，或者，kafka连接的“产生到kafka”阶段-Mongo Source可能会由于网络延迟而不同步，kafka可能会先保存未授权，然后保存授权消息。

注意，我说这一切都可能发生，因为kafka connect - Mongo Source不只是一个实例，它可以作为一个集群工作。并且他们在文档中没有说任何事情来确保kafka中的顺序与mongodb变更流中产生的顺序相同。

Answer 1

如果您保持事件的确定性生产（不是循环分区分配策略）

并且还设置

{
"producer.override.max.in.flight.requests.per.connection": "1"
}

然后生产订单将被保留。