1 package de.juplo.kafka;
3 import lombok.RequiredArgsConstructor;
4 import org.apache.kafka.common.TopicPartition;
10 @RequiredArgsConstructor
11 public class TestRecordHandler implements RecordHandler
13 private final RecordHandler handler;
15 Map<TopicPartition, Long> seenOffsets;
19 public void onNewRecord(
25 seenOffsets.put(new TopicPartition(topic, partition), offset);
30 public void addNumber(
35 MessageAddNumber message)
37 this.onNewRecord(topic, partition, offset, message);
38 handler.addNumber(topic, partition, offset, user, message);
42 public void calculateSum(
47 MessageCalculateSum message)
49 this.onNewRecord(topic, partition, offset, message);
50 handler.calculateSum(topic, partition, offset, user, message);