Поддерживает ли Kafka создание прогнозов из потоков нескольких категорий?
Мы используем EventStore для нашего решения, основанного на событиях. Мы хотим экспортировать события в Kafka и выполнять потоковую обработку с помощью Kafka. В EventStore каждый тип потока относится к категории, например, Заказ, Клиент, Платеж и т. Д. В каждой категории у вас есть отдельные потоки, например, Заказ-123, Заказ-124 и т. Д.
Теперь эти события поддерживают глобальный порядок во всех потоках, и можно употреблять это в таком порядке.
Мой вопрос: можно ли взять эти потоки и создать новый проецируемый поток в Kafka, сохранив при этом порядок событий. Например, возьмите эти 3 потока категорий и создайте новый, например CustomerActivity. Учитывая, что Order и Payment имеют CustomerId, он будет служить ключом раздела для новых потоков в разделе CustomerActivity.
То же самое для потоков Akka.Net.