X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FPollIntervalAwareConsumerRebalanceListener.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FPollIntervalAwareConsumerRebalanceListener.java;h=0000000000000000000000000000000000000000;hb=2d25525ef70a90709edc48bd9542d1b08a2888a2;hp=8abec12c2d856a8ef3e18434e74ab90ea99a0c1b;hpb=bfddb34a846a27a477d97eaa4db9221afbd6dbba;p=demos%2Fkafka%2Ftraining diff --git a/src/main/java/de/juplo/kafka/PollIntervalAwareConsumerRebalanceListener.java b/src/main/java/de/juplo/kafka/PollIntervalAwareConsumerRebalanceListener.java deleted file mode 100644 index 8abec12..0000000 --- a/src/main/java/de/juplo/kafka/PollIntervalAwareConsumerRebalanceListener.java +++ /dev/null @@ -1,9 +0,0 @@ -package de.juplo.kafka; - -import org.apache.kafka.clients.consumer.ConsumerRebalanceListener; - - -public interface PollIntervalAwareConsumerRebalanceListener extends ConsumerRebalanceListener -{ - default void beforeNextPoll() {} -}