juplo.de Git - demos/kafka/training/blob - src/test/java/de/juplo/kafka/TestRecordHandler.java

   1 package de.juplo.kafka;
   2
   3 import lombok.RequiredArgsConstructor;
   4 import org.apache.kafka.clients.consumer.ConsumerRecord;
   5
   6
   7 @RequiredArgsConstructor
   8 public abstract class TestRecordHandler<K, V> implements RecordHandler<K, V>
   9 {
  10   private final RecordHandler<K, V> handler;
  11
  12
  13   public abstract void onNewRecord(ConsumerRecord<K, V> record);
  14
  15
  16   @Override
  17   public void accept(ConsumerRecord<K, V> record)
  18   {
  19     this.onNewRecord(record);
  20     handler.accept(record);
  21   }
  22 }