1 package de.juplo.kafka;
3 import lombok.RequiredArgsConstructor;
4 import org.apache.kafka.clients.consumer.ConsumerRecord;
7 @RequiredArgsConstructor
8 public abstract class TestRecordHandler<K, V> implements RecordHandler<K, V>
10 private final RecordHandler<K, V> handler;
13 public abstract void onNewRecord(ConsumerRecord<K, V> record);
17 public void accept(ConsumerRecord<K, V> record)
19 this.onNewRecord(record);
20 handler.accept(record);
24 public void beforeNextPoll()
26 handler.beforeNextPoll();