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 
<pietro.gala...@gmail.com> 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
  

Reply via email to