Как инициировать правильный сброс процессора отслеживания событий - PullRequest
0 голосов
/ 08 апреля 2020

Я пытаюсь использовать Аксон TrackingEventProcessor для воспроизведения наших событий. При сбросе токена я получаю UnableToClaimTokenException, поскольку служба работает в распределенной конфигурации.

Есть ли способ решить эту проблему без использования Axon Server?

1 Ответ

0 голосов
/ 08 апреля 2020

Axon Server не имеет ничего общего с появлением UnableToClaimTokenException, Axon Server просто значительно упрощает процесс запуска воспроизведения.

Как исключение и javado c в состоянии TrackingEventProcessor вам нужно будет остановить все экземпляров данного TrackingEventProcessor до начала воспроизведения.

Таким образом, в распределенной установке вам придется остановите каждое дублирование данного TrackingEventProcessor до того, как сможете выполнить фактический вызов resetTokens на одном из них.

Без Axon Server, это означает, что вам придется создавать свои собственные конечные точки или CLI в пределах вашего приложение для остановки данных процессоров. Чтобы упростить это, вы, по сути, хотели бы иметь централизованную панель мониторинга, которая отображает все вхождения данного TrackingEventProcessor. Это именно то, чем является Axon Server, и, следовательно, значительно упрощает процесс.

Несмотря на это, определенно выполнимо создать это самостоятельно. Таким образом, когда дело доходит до запуска воспроизведения, вы сначала выключаете каждый экземпляр TEP до сброса.

...