1 package de.juplo.kafka;
3 import lombok.RequiredArgsConstructor;
4 import org.apache.kafka.clients.consumer.ConsumerRecord;
5 import org.apache.kafka.common.TopicPartition;
11 @RequiredArgsConstructor
12 public class TestRecordHandler<K, V> implements RecordHandler<K, V>
14 private final RecordHandler<K, V> handler;
16 Map<TopicPartition, Long> seenOffsets;
17 Set<ConsumerRecord<K, V>> receivedRecords;
20 public void onNewRecord(ConsumerRecord<K, V> record)
23 new TopicPartition(record.topic(), record.partition()),
25 receivedRecords.add(record);
29 public void accept(ConsumerRecord<K, V> record)
31 this.onNewRecord(record);
32 handler.accept(record);