1 package de.juplo.kafka;
3 import lombok.RequiredArgsConstructor;
4 import org.apache.kafka.clients.consumer.ConsumerRecord;
5 import org.apache.kafka.common.TopicPartition;
8 @RequiredArgsConstructor
9 public abstract class TestRecordHandler<K, V> implements RecordHandler<K, V>
11 private final RecordHandler<K, V> handler;
14 public abstract void onNewRecord(ConsumerRecord<K, V> record);
18 public void accept(ConsumerRecord<K, V> record)
20 this.onNewRecord(record);
21 handler.accept(record);
25 public void beforeNextPoll()
27 handler.beforeNextPoll();
31 public void onPartitionAssigned(TopicPartition tp)
33 handler.onPartitionAssigned(tp);
37 public void onPartitionRevoked(TopicPartition tp)
39 handler.onPartitionRevoked(tp);