Kafka与Akka.Net是否支持从多类别流创建投影并保留事件顺序

你说的需求完全可以落地，Kafka和Akka.NET Streams都有成熟的保序实现方案，具体实现逻辑如下：

• 你选择CustomerId作为CustomerActivity主题的分区键完全符合保序要求：Kafka原生保证同一分区内的消息严格按写入顺序存储、消费，只要保证同一个CustomerId关联的所有Order、Payment、Customer类事件都被路由到同一个分区，就能保证单个用户维度的事件顺序和EventStore的全局消费顺序完全一致。
• 实现注意点：从EventStore拉取事件时严格遵循全局顺序，写入Kafka时不要开启同一分区的异步并发写入逻辑，避免网络波动导致后拉取的事件被先写入分区。如果需要提升吞吐量，只需要按CustomerId哈希值拆分更多分区即可，不会破坏单用户维度的顺序。
• 如果你需要全量全局顺序而非单用户维度顺序，只需要将CustomerActivity主题设置为单分区即可，缺点是吞吐量会受单分区上限限制，绝大多数业务场景下用户维度的保序已经可以满足需求。

• Akka.NET Streams默认严格遵循消息处理顺序，只要你没有主动使用SelectAsyncUnordered这类显式打乱顺序的算子，整条流链路都会严格按上游事件输入顺序处理并输出到下游。
• 实现你的投影需求时，可以用GroupBy算子按CustomerId进行分组，每个子流单独处理单个用户的全量事件，处理完成后合并写入目标投影流，全程不会打乱事件原始顺序。
• 如果需要对接Kafka存储投影结果，可以配合Akka.NET Kafka的Producer组件，同样按CustomerId做分区路由，和上述Kafka的保序逻辑完全兼容。

注意：不要在处理链路中引入多线程并发处理同一分区/同一用户分组事件的逻辑，除非你自行实现了基于事件版本号的重排序机制，否则很容易破坏事件顺序。

内容的提问来源于stack exchange，提问作者epitka