Hi Pietro,
1) What do you mean by problems in counts due to multiple instances ? Also, do
you use Keys in your messages ?
2) If you want to maintain state and refer to that state when processing each
message, then yes you will need a state store. A state store will also be
needed if you want to I guess query that state externally.
Regards,
Neeraj
On Friday, 7 May, 2021, 01:47:59 am GMT+10, Pietro Galassi
<[email protected]> wrote:
Hi all,
hi have hope you can help me figure out this scenario.
I have a multiinstance microservice that consumes from a topic
(ordersTopic) all of them use the same consumer_group.
This microservice uses a KStream to aggregate (sum) topic events and
produces results on another topic (countTopic).
Have two questions:
1) Can i have problems on counts due to multiple instance of the same
microservies ?
2) I need rockDB and materialized view in order to store data ?
Thanks a lot.
Regards,
Pietro Galassi
