X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FCommittingConsumerRebalanceListener.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FCommittingConsumerRebalanceListener.java;h=8aa92c0b7661129b3984a85c6dfa9383d95c43ec;hb=384ed293b9d6d71f68031f92bd7bf60670a7ba4b;hp=0000000000000000000000000000000000000000;hpb=4210993f369acfa07ae8d388eb8e32517005de6f;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/CommittingConsumerRebalanceListener.java b/src/main/java/de/juplo/kafka/CommittingConsumerRebalanceListener.java
new file mode 100644
index 0000000..8aa92c0
--- /dev/null
+++ b/src/main/java/de/juplo/kafka/CommittingConsumerRebalanceListener.java
@@ -0,0 +1,10 @@
+package de.juplo.kafka;
+
+import org.apache.kafka.clients.consumer.ConsumerRebalanceListener;
+
+
+public interface CommittingConsumerRebalanceListener extends ConsumerRebalanceListener
+{
+  void enableCommits();
+  void disableCommits();
+}