X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FRecordHandler.java;h=47f984effad4720fd525dabff77d464e040d320e;hb=66ff7d205e66616de8aaca94503dbbcd7d281f6d;hp=3c9dd155afd2e771e1d5456666f47ca89617e188;hpb=fc682d9890787ef363b3e189f6f880a043f3c541;p=demos%2Fkafka%2Ftraining diff --git a/src/main/java/de/juplo/kafka/RecordHandler.java b/src/main/java/de/juplo/kafka/RecordHandler.java index 3c9dd15..47f984e 100644 --- a/src/main/java/de/juplo/kafka/RecordHandler.java +++ b/src/main/java/de/juplo/kafka/RecordHandler.java @@ -5,7 +5,18 @@ import org.apache.kafka.clients.consumer.ConsumerRecord; import java.util.function.Consumer; -public interface RecordHandler extends Consumer> +public interface RecordHandler { - default void beforeNextPoll() {} + void addNumber( + String topic, + Integer partition, + Long offset, + String user, + MessageAddNumber message); + void calculateSum( + String topic, + Integer partition, + Long offset, + String user, + MessageCalculateSum message); }