我们将 EventStore 用于我们的事件源解决方案。我们想将事件导出到 Kafka 并使用 Kafka 进行流处理。在 EventStore 中，每种类型的流都属于一个类别，例如 Order、Customer、Payment 等。在每个类别下，您都有单独的流，例如 Order-123、Order-124 等。
现在这些事件在所有流中维护全局顺序，并且可以按该顺序消费。
我的问题是，是否可以在保持事件顺序的同时获取这些流并在 Kafka 中创建一个新的投影流。例如，获取这 3 个类别流，并创建一个新的类别流，例如 CustomerActivity。鉴于 Order 和 Payment 具有 CustomerId，它将作为 CustomerAcivity 分区中新流的分区键。
同样的 Q，对于 Akka.Net 流。