GRÜN: Korrektur des über die verschärften Tests aufgedeckten Fehlers

[demos/kafka/training] / src / main / java / de / juplo / kafka / PollIntervalAwareConsumerRebalanceListener.java

diff --git a/src/main/java/de/juplo/kafka/PollIntervalAwareConsumerRebalanceListener.java b/src/main/java/de/juplo/kafka/PollIntervalAwareConsumerRebalanceListener.java
index 8abec12..c59418c 100644 (file)
--- a/src/main/java/de/juplo/kafka/PollIntervalAwareConsumerRebalanceListener.java
+++ b/src/main/java/de/juplo/kafka/PollIntervalAwareConsumerRebalanceListener.java
@@ -6,4 +6,7 @@ import org.apache.kafka.clients.consumer.ConsumerRebalanceListener;
 public interface PollIntervalAwareConsumerRebalanceListener extends ConsumerRebalanceListener
 {
   default void beforeNextPoll() {}
+
+  default void enableCommits() {}
+  default void disableCommits() {}
 }