X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationRebalanceListener.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationRebalanceListener.java;h=5a013935a32f2d1e90b61e60916f9cd3c734ca6e;hb=7c0368363c3e5dbb7eb2a08f343187a93f050617;hp=542af2d563a42466f971546f01e7f38eb9a5e1ed;hpb=4a8642d0c36413cbc283d35dda8977b0e9320372;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/ApplicationRebalanceListener.java b/src/main/java/de/juplo/kafka/ApplicationRebalanceListener.java
index 542af2d..5a01393 100644
--- a/src/main/java/de/juplo/kafka/ApplicationRebalanceListener.java
+++ b/src/main/java/de/juplo/kafka/ApplicationRebalanceListener.java
@@ -62,7 +62,7 @@ public class ApplicationRebalanceListener implements PollIntervalAwareConsumerRe
           offset);
       if (commitsEnabled)
       {
-        Map<String, Long> removed = recordHandler.removePartition(partition);
+        Map<String, AdderResult> removed = recordHandler.removePartition(partition);
         stateRepository.save(new StateDocument(partition, removed, offset));
       }
       else