The FractionAggregator class has two fields (int trues, int total), and it is up to Kafka to keep track of the accumulated number. (perhaps someone who knows Kafka better could elaborate on how Kafka stores work "under the hood")