apache-kafka - 如果在收到创建消息之前收到更新消息,如何处理kafka消息?

标签 apache-kafka kafka-consumer-api spring-kafka

我们有多个 kafka 分区。

有 2 项服务。第一个服务创建数据并将响应发送回 UI,还向 Kafka 发送创建消息。几分之一秒后,更新请求被发送到第一个服务,并且第一个服务因此将该更新请求发送到第二个服务。我们不定义发送数据的分区。

假设创建消息发送到分区 1,更新消息发送到分区 2。

现在的问题是,有时更新消息会先于创建消息执行。由于创建消息没有执行,并且第二个服务中没有数据,因此更新消息失败。

是否有某种方法可以确保更新消息在创建消息后执行?

最佳答案

没有;你需要将它们发送到同一个分区;如果您向记录添加(例如客户ID),默认分区程序会将它们发送到同一分区。

关于apache-kafka - 如果在收到创建消息之前收到更新消息,如何处理kafka消息?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/67414003/

相关文章:

java - spring-kafka监听并发

.net - 如何在 .Net 中使用 Confluence.Kafka 从特定 TopicPartitionOffset 进行消费

json - Json 不适合 Avro 的什么场景

java - 如何让多个客户倾听同一消费者的声音?

apache-kafka - 是否可以从 Kafka 服务器杀死消费者?

java - 如何在 Spring Boot 中反序列化 Kafka 主题中的 Json 字符串

C++ with Kafka - 消费者刚刚收到一些生产者消息

java - Kafka Consumer仅在两条消息堆叠时才读取消息

hadoop - Apache Kafka 中的魔法字节

java - 通过 Kafka 发送/接收 Java 对象