我们有多个 kafka 分区。
有 2 项服务。第一个服务创建数据并将响应发送回 UI,还向 Kafka 发送创建消息。几分之一秒后,更新请求被发送到第一个服务,并且第一个服务因此将该更新请求发送到第二个服务。我们不定义发送数据的分区。
假设创建消息发送到分区 1,更新消息发送到分区 2。
现在的问题是,有时更新消息会先于创建消息执行。由于创建消息没有执行,并且第二个服务中没有数据,因此更新消息失败。
是否有某种方法可以确保更新消息在创建消息后执行?
最佳答案
没有;你需要将它们发送到同一个分区;如果您向记录添加键
(例如客户ID),默认分区程序会将它们发送到同一分区。
关于apache-kafka - 如果在收到创建消息之前收到更新消息,如何处理kafka消息?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/67414003/