Hello
We have a projection which stops working when it handles a lot of messages, like more than 100 000. It does nothing more than partitioning the messages in different streams.
The projection just stops working, no errors in state. It just does not pick up anymore new messages which are saved to Event Store
fromStreams(’$ce-Dog’, ‘$ce-Cat’, ‘$ce-Bird’, ‘$ce-Rabbit’)
.when({
$any: (s, e) => {
if (!e || !e.eventType || e.eventType.startsWith(“Bulk”) || !e.streamId) {
return;
}
if (e.streamId.startsWith(“Dog-”)) {
linkTo(‘Dogs’, e);
}
if (e.streamId.startsWith(“Cat-”)) {
linkTo(‘Cats’, e);
}
if (e.streamId.startsWith(“Bird-”)) {
linkTo(‘Birds’, e);
}
if (e.streamId.startsWith(“Rabbit-”)) {
linkTo(‘Rabbits’, e);
}
}
});
``
What could here be the issue?
Many thanks
Maarten