+ this.onNewRecord(topic, partition, offset, message);
+ handler.addNumber(topic, partition, offset, user, message);
+ }
+
+ @Override
+ public void calculateSum(
+ String topic,
+ Integer partition,
+ Long offset,
+ String user,
+ MessageCalculateSum message)
+ {
+ this.onNewRecord(topic, partition, offset, message);
+ handler.calculateSum(topic, partition, offset, user, message);