X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FRecordHandler.java;h=47f984effad4720fd525dabff77d464e040d320e;hb=66ff7d205e66616de8aaca94503dbbcd7d281f6d;hp=ff2f1930b75faaa89d4aec99f7629b6c3d3e8398;hpb=2d84eda74475aaffff11ddfebe56d309b9aff2e9;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 ff2f193..47f984e 100644 --- a/src/main/java/de/juplo/kafka/RecordHandler.java +++ b/src/main/java/de/juplo/kafka/RecordHandler.java @@ -1,16 +1,22 @@ package de.juplo.kafka; import org.apache.kafka.clients.consumer.ConsumerRecord; -import org.apache.kafka.common.TopicPartition; import java.util.function.Consumer; -public interface RecordHandler extends Consumer> +public interface RecordHandler { - default void beforeNextPoll() {} - - default void onPartitionAssigned(TopicPartition tp) {} - - default void onPartitionRevoked(TopicPartition tp) {} + void addNumber( + String topic, + Integer partition, + Long offset, + String user, + MessageAddNumber message); + void calculateSum( + String topic, + Integer partition, + Long offset, + String user, + MessageCalculateSum message); }