确保有序处理消息

Question

      message2, message1 kafka
     ------------------------------
             |message1       |message2
             |               |
         Instace1         Instance2

在下面的示例中，我有两个正在处理来自kafka的消息的服务实例，但我希望确保message2只在message1之后处理。

显然,通过将一个实例配置为仅从特定分区消费,可以很容易地解决这种情况,该分区将存储带有公共标识符的消息：

message2, message1 kafka
--------------------------------
       | message2
       | message1
     Instance1        Instance2

现在顺序得到了保证，message2将永远不会在message1之前处理。

但是，我在想这个问题是否可以用另一种方式来解决，直接在代码中而不是依赖基础设施？这看起来可能是微服务架构中的一个标准问题，但我不确定哪种方法是解决它的首选方法？

Answer 1

我建议基础设施是更“正确”的方法，但是用代码解决这个问题应该是可行的：

如果您有一个消息生成器，请将直接在前的消息的标识符附加到消息中，并且在使用该消息之前确保您使用了直接在前的消息。

如果您有多个生产者，这将变得更加棘手，因为您必须同步标识符。