+++ /dev/null
-package de.juplo.kafka;
-
-import lombok.RequiredArgsConstructor;
-import org.apache.kafka.clients.consumer.ConsumerRecord;
-
-
-@RequiredArgsConstructor
-public abstract class TestRecordHandler<K, V> implements RecordHandler<K, V>
-{
- private final RecordHandler<K, V> handler;
-
-
- public abstract void onNewRecord(ConsumerRecord<K, V> record);
-
-
- @Override
- public void accept(ConsumerRecord<K, V> record)
- {
- this.onNewRecord(record);
- handler.accept(record);
- }
-}