Fixes für Setup/README.sh aus 'deserialization' in 'stored-offsets' gemerged
[demos/kafka/training] / src / main / java / de / juplo / kafka / RecordHandler.java
1 package de.juplo.kafka;
2
3 import org.apache.kafka.clients.consumer.ConsumerRecord;
4
5 import java.util.function.Consumer;
6
7
8 public interface RecordHandler<K, V> extends Consumer<ConsumerRecord<K,V>>
9 {
10   default void beforeNextPoll() {}
11 }