Example i have topic with 4 partition and 2 instance ksqdb. As I understood from the documentation, each instance will take on two partitions.
Next i run query that SUM ALL TICKET VALUES
, every instance calculate for self partitions but but where will the final aggregation(sum) of the last two values occur?
SELECT
SUM(TICKET_TOTAL_VALUE) AS TOTAL_VALUE
FROM MOVIE_TICKET_SALES