Как я могу создать "n" число произвольных акторов для одновременной обработки?

Question

Я очень новичок в Akka (только начал искать сегодня) и считаю, что мне нужно создать программу, использующую Akka, которая читает сообщения от Kafka. Скажем, например, мое сообщение выглядит как "{погода: дождливо, почтовый индекс: 123456, температура: 55}". Я хотел бы направить каждое сообщение в том виде, в котором оно поступает на основе определенного почтового индекса, в Actor, который обрабатывает сообщения, связанные с этим почтовым индексом.

Полагаю, у меня здесь 2 проблемы. 1) В начале моего заявления я не уверен, какое количество актеров мне понадобится.

2) Как указать, что Актер принадлежит к определенному почтовому индексу и направить туда сообщения?

3 месяца) Это то, для чего я могу использовать Акку + Кафку? Или что-то более подходящее для потоковой передачи, например, Alpakka?

Answer 1

1. не проблема, учитывая ответ на 2
2. взгляните на разбиение кластера: https://doc.akka.io/docs/akka/current/cluster-sharding.html
3. действительно зависит от того, что именно вам нужно, вы также можете использовать чистый поток kafka.

Если вам нужно уменьшить масштаб (т. Е. Иметь больше, чем может уместиться в одной JVM с учетом требований к объему / пропускной способности), то вам следует рассмотреть либо сегментирование кластера, либо чистые потоки kafka. Какой другой вопрос.