Hello Pietro,
1) If you are using the Streams DSL with an aggregation, it would
repartition the input streams by the aggregation field for data
parallelism, and hence multiple instances would be able to do the
aggregation in parallel and independently with correct results.
2) Short answer is "prob
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).
