Hello people,
I would like to ask for help because I’m suffering from problems with projections that are not executed.
In our project we decided to use axon + kafka + mongodb being kafka and mongodb that we already use.
What happens is that we have 3 projections of our aggregate in a query project separate from the command project, what happens is that of the 3 projections for the same aggregate sometimes not all are executed, simply nothing is done.
And our query base is totally out of sync, it just doesn’t work, we’ve tried everything, it only works again if we delete the record referring to the processorName of the trackingtokens, no error log is shown.
We are using version 4.5 of kafka extension + 4.5 of mongo + 4.5.3 of axon.
Does anyone have any light for us to help us on how to solve this problem?
Our configuration in the query project is as below:
axon:
event-handling:
processors:
stock-projection:
source: streamableKafkaMessageSource
mode: POOLED
thread-count: 6
batch-size: 20
initial-segment-count: 6
sequencing-policy: sequentialPerAggregatePolicy
notification-projection:
source: streamableKafkaMessageSource
mode: POOLED
thread-count: 6
batch-size: 4
initial-segment-count: 4
sequencing-policy: sequentialPerAggregatePolicy
stock-replay-projection:
source: streamableKafkaMessageSource
mode: POOLED
thread-count: 8
batch-size: 15
initial-segment-count: 4
sequencing-policy: sequentialPerAggregatePolicy
log-projection:
source: streamableKafkaMessageSource
mode: POOLED
thread-count: 4
batch-size: 20
initial-segment-count: 2
serializer:
general: JACKSON
events: JACKSON
messages: JACKSON
kafka:
clientid: stock-query-events-consumer
defaulttopic: stockservice.stock.events
consumer:
enable-auto-commit: true
event-processor-mode: POOLED_STREAMING
bootstrapservers: ${kafka.server}:${kafka.port}
properties:
group-id: “stockservice.stock.events.query-consumer”
auto-offset-reset: earliest
properties:
security.protocol: PLAINTEXT
distributed:
enabled: true